Lines Matching refs:sender
51 auto [sender, receiver] = Channel<size_t>::OpenChannel();
55 std::thread worker([sender = sender, count]() mutable {
57 EXPECT_EQ(sender.Send(index), Channel<size_t>::NO_ERROR);
80 auto [sender, receiver] = Channel<size_t>::OpenChannel();
84 std::thread worker([sender = sender, count]() mutable {
86 EXPECT_EQ(sender.Send(index), Channel<size_t>::NO_ERROR);
109 auto [sender, receiver] = Channel<size_t>::OpenChannel();
111 EXPECT_EQ(sender.Send(data), Channel<size_t>::INACTIVE_CHANNEL);
122 auto [sender, receiver] = Channel<size_t>::OpenChannel();
127 EXPECT_EQ(sender.Send(data++), Channel<size_t>::NO_ERROR);
129 EXPECT_EQ(sender.Send(data), Channel<size_t>::QUEUE_IS_FULL);