[fix][test] Store receiveAsync callback in lvalue to clarify lifetime semantics

geniusjoe · geniusjoe · commit e2cd786ce38d · 2026-05-25T17:05:35.000+08:00
diff --git a/tests/TypedMessageTest.cc b/tests/TypedMessageTest.cc
@@ -65,16 +65,16 @@ TEST(TypedMessageTest, testReceive) {
             ASSERT_EQ(ResultOk, consumer.receive(msg, 3000, intDecoder));
         } else {
             Latch latch{1};
-            consumer.receiveAsync<int>(
+            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 = receivedMsg;
                     }
                     latch.countdown();
-                },
-                intDecoder);
+                };
+            consumer.receiveAsync<int>(callback, intDecoder);
             ASSERT_TRUE(latch.wait(std::chrono::seconds(1)));
         }
 

Original file line number	Diff line number	Diff line change
`@@ -65,16 +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<int>(`
	`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`	`73`	`msg = receivedMsg;`
`74`	`74`	`}`
`75`	`75`	`latch.countdown();`
`76`		`- },`
`77`		`- intDecoder);`
	`76`	`+ };`
	`77`	`+ consumer.receiveAsync<int>(callback, intDecoder);`
`78`	`78`	`ASSERT_TRUE(latch.wait(std::chrono::seconds(1)));`
`79`	`79`	`}`
`80`	`80`