• Home
  • History
  • Annotate
  • Raw
  • Download

Lines Matching refs:queue

58   TestMessageQueue queue;  in TEST_F()  local
60 queue.SendMessage(EmptyMessage{}); in TEST_F()
61 ASSERT_TRUE(std::holds_alternative<EmptyMessage>(queue.ReceiveMessage())); in TEST_F()
63 queue.SendMessage(IntMessage{42}); in TEST_F()
64 ASSERT_TRUE(std::holds_alternative<IntMessage>(queue.ReceiveMessage())); in TEST_F()
66 queue.SendMessage(OtherIntMessage{43}); in TEST_F()
67 ASSERT_TRUE(std::holds_alternative<OtherIntMessage>(queue.ReceiveMessage())); in TEST_F()
69 queue.SendMessage(TwoIntMessage{1, 2}); in TEST_F()
70 ASSERT_TRUE(std::holds_alternative<TwoIntMessage>(queue.ReceiveMessage())); in TEST_F()
72 queue.SendMessage(StringMessage{"Hello, World!"}); in TEST_F()
73 ASSERT_TRUE(std::holds_alternative<StringMessage>(queue.ReceiveMessage())); in TEST_F()
77 TestMessageQueue queue; in TEST_F() local
82 queue.SetTimeout(kDuration); in TEST_F()
83 ASSERT_TRUE(std::holds_alternative<TimeoutExpiredMessage>(queue.ReceiveMessage())); in TEST_F()
110 TestMessageQueue queue; in TEST_F() local
112 queue.SendMessage(EmptyMessage{}); in TEST_F()
113 queue.SendMessage(IntMessage{42}); in TEST_F()
114 queue.SendMessage(OtherIntMessage{43}); in TEST_F()
115 queue.SendMessage(TwoIntMessage{1, 2}); in TEST_F()
116 queue.SendMessage(StringMessage{"Hello, World!"}); in TEST_F()
117 queue.SetTimeout(500); in TEST_F()
128 queue.SwitchReceive( in TEST_F()
167 TestMessageQueue queue; in TEST_F() local
169 queue.SendMessage(EmptyMessage{}); in TEST_F()
170 queue.SendMessage(IntMessage{42}); in TEST_F()
171 queue.SendMessage(OtherIntMessage{43}); in TEST_F()
172 queue.SendMessage(TwoIntMessage{1, 2}); in TEST_F()
173 queue.SendMessage(StringMessage{"Hello, World!"}); in TEST_F()
174 queue.SetTimeout(500); in TEST_F()
179 queue.SwitchReceive([&]([[maybe_unused]] auto message) { pending_messages--; }); in TEST_F()
184 TestMessageQueue queue; in TEST_F() local
186 queue.SendMessage(EmptyMessage{}); in TEST_F()
187 queue.SendMessage(IntMessage{42}); in TEST_F()
188 queue.SendMessage(OtherIntMessage{43}); in TEST_F()
189 queue.SendMessage(TwoIntMessage{1, 2}); in TEST_F()
190 queue.SendMessage(StringMessage{"Hello, World!"}); in TEST_F()
191 queue.SetTimeout(500); in TEST_F()
195 queue.SwitchReceive( in TEST_F()
208 TestMessageQueue queue; in TEST_F() local
210 queue.SendMessage(EmptyMessage{}); in TEST_F()
213 queue.SwitchReceive<bool>([&]([[maybe_unused]] const EmptyMessage& message) { return true; }, in TEST_F()
216 queue.SendMessage(IntMessage{42}); in TEST_F()
219 queue.SwitchReceive<bool>([&]([[maybe_unused]] const EmptyMessage& message) { return true; }, in TEST_F()
224 TestMessageQueue queue; in TEST_F() local
236 queue.SendMessage(message); in TEST_F()
238 queue.SetTimeout(500); in TEST_F()
245 auto message = queue.ReceiveMessage(); in TEST_F()
257 ASSERT_TRUE(std::holds_alternative<TimeoutExpiredMessage>(queue.ReceiveMessage())); in TEST_F()