Sha256: 630daf958caa06e0085e06a68664cb08bd16ee6f81276f00ac878919caafd573
Contents?: true
Size: 487 Bytes
Versions: 133
Compression:
Stored size: 487 Bytes
Contents
# frozen_string_literal: true
RSpec.describe Deimos::Backends::KafkaAsync do
include_context 'with publish_backend'
it 'should publish to Kafka asynchronously' do
producer = instance_double(Phobos::Producer::ClassMethods::PublicAPI)
expect(producer).to receive(:async_publish_list).with(messages.map(&:encoded_hash))
expect(described_class).to receive(:producer).and_return(producer)
described_class.publish(producer_class: MyProducer, messages: messages)
end
end
Version data entries
133 entries across 133 versions & 3 rubygems