Lines Matching refs:message
43 std::string message; member
121 [&]([[maybe_unused]] const EmptyMessage& message) { in TEST_F() argument
125 [&](const IntMessage& message) { in TEST_F() argument
129 ASSERT_EQ(message.value, 42); in TEST_F()
131 [&](const OtherIntMessage& message) { in TEST_F() argument
135 ASSERT_EQ(message.other_value, 43); in TEST_F()
138 [&]([[maybe_unused]] const TimeoutExpiredMessage& message) { in TEST_F() argument
142 [&](const TwoIntMessage& message) { in TEST_F() argument
146 ASSERT_EQ(message.value1, 1); in TEST_F()
147 ASSERT_EQ(message.value2, 2); in TEST_F()
149 [&](const StringMessage& message) { in TEST_F() argument
153 ASSERT_EQ(message.message, "Hello, World!"); in TEST_F()
171 queue.SwitchReceive([&]([[maybe_unused]] auto message) { pending_messages--; }); in TEST_F() argument
188 [&](const StringMessage& message) { in TEST_F() argument
189 ASSERT_EQ(message.message, "Hello, World!"); in TEST_F()
192 [&]([[maybe_unused]] const auto& message) { in TEST_F() argument
193 const bool is_string{std::is_same<StringMessage, decltype(message)>()}; in TEST_F()
205 queue.SwitchReceive<bool>([&]([[maybe_unused]] const EmptyMessage& message) { return true; }, in TEST_F() argument
206 [&]([[maybe_unused]] const auto& message) { return false; })); in TEST_F() argument
211 queue.SwitchReceive<bool>([&]([[maybe_unused]] const EmptyMessage& message) { return true; }, in TEST_F() argument
212 [&]([[maybe_unused]] const auto& message) { return false; })); in TEST_F() argument
227 for (const auto& message : messages) { in TEST_F() local
228 queue.SendMessage(message); in TEST_F()
237 auto message = queue.ReceiveMessage(); in TEST_F() local
238 if (std::holds_alternative<TimeoutExpiredMessage>(message)) { in TEST_F()
242 ASSERT_EQ(message.index(), messages[i].index()); in TEST_F()