Sha256: f03bf11e9d0735ba1a4779b1cb41da29cc5830a71e844c8754c4edb7cdb99ec8
Contents?: true
Size: 475 Bytes
Versions: 133
Compression:
Stored size: 475 Bytes
Contents
# frozen_string_literal: true
RSpec.describe Deimos::Backends::Kafka do
include_context 'with publish_backend'
it 'should publish to Kafka synchronously' do
producer = instance_double(Phobos::Producer::ClassMethods::PublicAPI)
expect(producer).to receive(: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