Lines Matching refs:sender

51     auto [sender, receiver] = Channel<size_t>::OpenChannel();
55     std::thread worker([sender = sender, count]() mutable {  in __anon6484951c0202()
57             EXPECT_EQ(sender.Send(index), Channel<size_t>::NO_ERROR);  in __anon6484951c0202()
80     auto [sender, receiver] = Channel<size_t>::OpenChannel();
84     std::thread worker([sender = sender, count]() mutable {  in __anon6484951c0302()
86             EXPECT_EQ(sender.Send(index), Channel<size_t>::NO_ERROR);  in __anon6484951c0302()
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);