diff options
| author | Henning Baldersheim <balder@yahoo-inc.com> | 2019-12-04 20:21:41 +0000 |
|---|---|---|
| committer | Henning Baldersheim <balder@yahoo-inc.com> | 2019-12-04 20:21:41 +0000 |
| commit | b10bb5788dac0882a9e9d07c5c22581c006398a5 (patch) | |
| tree | 31fefe5cd38e50f0f3852fe3d0d3e3ca9173b688 /messagebus | |
| parent | 3449bdead4b7f1db519c242e7b02f756fa169947 (diff) | |
Use getReplyNow and deque() for immediate poll.
Diffstat (limited to 'messagebus')
| -rw-r--r-- | messagebus/src/tests/context/context.cpp | 6 | ||||
| -rw-r--r-- | messagebus/src/tests/routable/routable.cpp | 4 |
2 files changed, 5 insertions, 5 deletions
diff --git a/messagebus/src/tests/context/context.cpp b/messagebus/src/tests/context/context.cpp index 39a7ca7b467..12539b16b11 100644 --- a/messagebus/src/tests/context/context.cpp +++ b/messagebus/src/tests/context/context.cpp @@ -77,17 +77,17 @@ Test::Main() } EXPECT_EQUAL(queue.size(), 3u); { - Reply::UP reply = Reply::UP((Reply*)queue.dequeue(duration::zero()).release()); + Reply::UP reply = Reply::UP((Reply*)queue.dequeue().release()); ASSERT_TRUE(reply); EXPECT_EQUAL(reply->getContext().value.UINT64, 10u); } { - Reply::UP reply = Reply::UP((Reply*)queue.dequeue(duration::zero()).release()); + Reply::UP reply = Reply::UP((Reply*)queue.dequeue().release()); ASSERT_TRUE(reply); EXPECT_EQUAL(reply->getContext().value.UINT64, 20u); } { - Reply::UP reply = Reply::UP((Reply*)queue.dequeue(duration::zero()).release()); + Reply::UP reply = Reply::UP((Reply*)queue.dequeue().release()); ASSERT_TRUE(reply); EXPECT_EQUAL(reply->getContext().value.UINT64, 30u); } diff --git a/messagebus/src/tests/routable/routable.cpp b/messagebus/src/tests/routable/routable.cpp index 88db25fa9c7..5b1d14a657b 100644 --- a/messagebus/src/tests/routable/routable.cpp +++ b/messagebus/src/tests/routable/routable.cpp @@ -73,7 +73,7 @@ Test::Main() msg.pushHandler(handler); msg.discard(); - Reply::UP reply = handler.getReply(duration::zero()); + Reply::UP reply = handler.getReplyNow(); ASSERT_FALSE(reply); } { @@ -86,7 +86,7 @@ Test::Main() reply.swapState(msg); reply.discard(); - Reply::UP ap = handler.getReply(duration::zero()); + Reply::UP ap = handler.getReplyNow(); ASSERT_FALSE(ap); } |