Sha256: 0ed228979ccc90cc5432373151c2aaa203b1ac0ee23b3d7c7425314ccee171d6
Contents?: true
Size: 1.6 KB
Versions: 24
Compression:
Stored size: 1.6 KB
Contents
# frozen_string_literal: true
describe Rdkafka::Producer::DeliveryHandle do
let(:response) { 0 }
subject do
Rdkafka::Producer::DeliveryHandle.new.tap do |handle|
handle[:pending] = pending_handle
handle[:response] = response
handle[:partition] = 2
handle[:offset] = 100
handle[:topic_name] = FFI::MemoryPointer.from_string("produce_test_topic")
end
end
describe "#wait" do
let(:pending_handle) { true }
it "should wait until the timeout and then raise an error" do
expect {
subject.wait(max_wait_timeout: 0.1)
}.to raise_error Rdkafka::Producer::DeliveryHandle::WaitTimeoutError, /delivery/
end
context "when not pending anymore and no error" do
let(:pending_handle) { false }
it "should return a delivery report" do
report = subject.wait
expect(report.partition).to eq(2)
expect(report.offset).to eq(100)
expect(report.topic_name).to eq("produce_test_topic")
end
it "should wait without a timeout" do
report = subject.wait(max_wait_timeout: nil)
expect(report.partition).to eq(2)
expect(report.offset).to eq(100)
expect(report.topic_name).to eq("produce_test_topic")
end
end
end
describe '#create_result' do
let(:pending_handle) { false }
let(:report) { subject.create_result }
context 'when response is 0' do
it { expect(report.error).to eq(nil) }
end
context 'when response is not 0' do
let(:response) { 1 }
it { expect(report.error).to eq(Rdkafka::RdkafkaError.new(response)) }
end
end
end
Version data entries
24 entries across 24 versions & 1 rubygems