Sha256: 355249838830a6e641e5daa5bcb22dcba8304813d233995081e9ba8373ee3ae9
Contents?: true
Size: 323 Bytes
Versions: 20
Compression:
Stored size: 323 Bytes
Contents
# frozen_string_literal: true
RSpec.describe Deimos::Backends::Kafka do
include_context 'with publish_backend'
it 'should publish to Kafka synchronously' do
expect(Karafka.producer).to receive(:produce_many_sync).with(messages)
described_class.publish(producer_class: MyProducer, messages: messages)
end
end
Version data entries
20 entries across 20 versions & 1 rubygems