We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d57e23a commit 5f304a7Copy full SHA for 5f304a7
spec/rdkafka/producer/client_spec.rb
@@ -42,13 +42,13 @@
42
43
it "polls the native with default 250ms timeout" do
44
polling_loop_expects do
45
- expect(Rdkafka::Bindings).to receive(:rd_kafka_poll).with(instance_of(FFI::Pointer), 250)
+ expect(Rdkafka::Bindings).to receive(:rd_kafka_poll).with(instance_of(FFI::Pointer), 250).at_least(:once)
46
end
47
48
49
it "check the out queue of native client" do
50
51
- expect(Rdkafka::Bindings).to receive(:rd_kafka_outq_len).with(native)
+ expect(Rdkafka::Bindings).to receive(:rd_kafka_outq_len).with(native).at_least(:once)
52
53
54
0 commit comments