diff --git a/tests/TypedMessageTest.cc b/tests/TypedMessageTest.cc index 9a61bfeb..4e416b87 100644 --- a/tests/TypedMessageTest.cc +++ b/tests/TypedMessageTest.cc @@ -65,15 +65,16 @@ TEST(TypedMessageTest, testReceive) { ASSERT_EQ(ResultOk, consumer.receive(msg, 3000, intDecoder)); } else { Latch latch{1}; - consumer.receiveAsync( + std::function&)> callback = [&latch, &msg, &msgMutex](Result result, const TypedMessage& receivedMsg) { ASSERT_EQ(ResultOk, result); { std::lock_guard lock{msgMutex}; - msg = TypedMessage{receivedMsg, intDecoder}; + msg = receivedMsg; } latch.countdown(); - }); + }; + consumer.receiveAsync(callback, intDecoder); ASSERT_TRUE(latch.wait(std::chrono::seconds(1))); }