[fix][client-cpp] Fix TypedMessageTest to use receiveAsync<T> template overload with decoder (#580)

geniusjoe · web-flow · commit aedb9255748c · 2026-05-26T20:28:46.000+08:00
diff --git 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<void(Result result, const TypedMessage<int>&)> callback =
                 [&latch, &msg, &msgMutex](Result result, const TypedMessage<int>& receivedMsg) {
                     ASSERT_EQ(ResultOk, result);
                     {
                         std::lock_guard<std::mutex> lock{msgMutex};
-                        msg = TypedMessage<int>{receivedMsg, intDecoder};
+                        msg = receivedMsg;
                     }
                     latch.countdown();
-                });
+                };
+            consumer.receiveAsync<int>(callback, intDecoder);
             ASSERT_TRUE(latch.wait(std::chrono::seconds(1)));
         }
 

Original file line number	Diff line number	Diff line change
`@@ -65,15 +65,16 @@ TEST(TypedMessageTest, testReceive) {`
`65`	`65`	`ASSERT_EQ(ResultOk, consumer.receive(msg, 3000, intDecoder));`
`66`	`66`	`} else {`
`67`	`67`	`Latch latch{1};`
`68`		`- consumer.receiveAsync(`
	`68`	`+ std::function<void(Result result, const TypedMessage<int>&)> callback =`
`69`	`69`	`[&latch, &msg, &msgMutex](Result result, const TypedMessage<int>& receivedMsg) {`
`70`	`70`	`ASSERT_EQ(ResultOk, result);`
`71`	`71`	`{`
`72`	`72`	`std::lock_guard<std::mutex> lock{msgMutex};`
`73`		`- msg = TypedMessage<int>{receivedMsg, intDecoder};`
	`73`	`+ msg = receivedMsg;`
`74`	`74`	`}`
`75`	`75`	`latch.countdown();`
`76`		`- });`
	`76`	`+ };`
	`77`	`+ consumer.receiveAsync<int>(callback, intDecoder);`
`77`	`78`	`ASSERT_TRUE(latch.wait(std::chrono::seconds(1)));`
`78`	`79`	`}`
`79`	`80`