From 3151b3ef4b43ece5d16caa2bd02506966e8a6878 Mon Sep 17 00:00:00 2001 From: jway Date: Tue, 7 Oct 2014 15:27:36 -0700 Subject: [PATCH] push method returns executing Promise --- lib/hermann/provider/java_producer.rb | 2 +- spec/providers/java_producer_spec.rb | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/lib/hermann/provider/java_producer.rb b/lib/hermann/provider/java_producer.rb index 9a1ace1..d9d9f7a 100644 --- a/lib/hermann/provider/java_producer.rb +++ b/lib/hermann/provider/java_producer.rb @@ -37,7 +37,7 @@ module Hermann # data to the kafka broker. Upon execution the Promise's status # will be set def push_single(msg) - Concurrent::Promise.new { + Concurrent::Promise.execute { data = ProducerUtil::KeyedMessage.new(@topic, msg) @producer.send(data) } diff --git a/spec/providers/java_producer_spec.rb b/spec/providers/java_producer_spec.rb index 1ce660f..8469a74 100644 --- a/spec/providers/java_producer_spec.rb +++ b/spec/providers/java_producer_spec.rb @@ -13,7 +13,7 @@ describe Hermann::Provider::JavaProducer do context 'error conditions' do shared_examples 'an error condition' do it 'should be rejected' do - promise = producer.push_single('rspec').execute.wait(1) + promise = producer.push_single('rspec').wait(1) expect(promise).to be_rejected expect { promise.value! }.to raise_error end