Sha256: c6a0518c38f7880643a37c82b041a19b1e2fdb7d95d8ee20ffbdf358967740c0

Contents?: true

Size: 1.04 KB

Versions: 16

Compression:

Stored size: 1.04 KB

Contents

require "spec_helper"

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
    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)
      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)
      end
    end
  end
end

Version data entries

16 entries across 16 versions & 2 rubygems

Version Path
rdkafka-0.12.1 spec/rdkafka/producer/delivery_handle_spec.rb
karafka-rdkafka-0.12.2 spec/rdkafka/producer/delivery_handle_spec.rb
karafka-rdkafka-0.12.1 spec/rdkafka/producer/delivery_handle_spec.rb
karafka-rdkafka-0.12.1.beta1 spec/rdkafka/producer/delivery_handle_spec.rb
karafka-rdkafka-0.12.0 spec/rdkafka/producer/delivery_handle_spec.rb
rdkafka-0.12.0 spec/rdkafka/producer/delivery_handle_spec.rb
rdkafka-0.12.0.beta.4 spec/rdkafka/producer/delivery_handle_spec.rb
rdkafka-0.12.0.beta.3 spec/rdkafka/producer/delivery_handle_spec.rb
rdkafka-0.12.0.beta.2 spec/rdkafka/producer/delivery_handle_spec.rb
rdkafka-0.12.0.beta.1 spec/rdkafka/producer/delivery_handle_spec.rb
rdkafka-0.12.0.beta.0 spec/rdkafka/producer/delivery_handle_spec.rb
rdkafka-0.11.1 spec/rdkafka/producer/delivery_handle_spec.rb
rdkafka-0.11.0 spec/rdkafka/producer/delivery_handle_spec.rb
rdkafka-0.10.0 spec/rdkafka/producer/delivery_handle_spec.rb
rdkafka-0.9.0 spec/rdkafka/producer/delivery_handle_spec.rb
rdkafka-0.8.1 spec/rdkafka/producer/delivery_handle_spec.rb