Searched defs:read_task (Results 1 – 8 of 8) sorted by relevance
72 ReaderTask<DatagramReader> read_task(channel.channel()); in TEST() local92 ReaderTask<DatagramReader> read_task(channel.channel()); in TEST() local112 ReaderTask<ReliableByteReader> read_task(channel.channel()); in TEST() local132 ReaderTask<ReliableByteReader> read_task(channel.channel()); in TEST() local
279 TryToReadUntilClosed read_task(pair->first()); in TEST() local398 ReadTask read_task(*pair); in TEST() local499 TryToReadUntilClosed read_task(pair->first()); in TEST() local
134 ReaderTask<ByteReader> read_task(channel.channel(), 1); in TEST_F() local174 ReaderTask<ByteReader> read_task(channel.channel(), 1); in TEST_F() local
82 PendFuncTask read_task([&](Context& cx) -> Poll<> { in TEST() local
50 std::function<void()> read_task; member55 bool Enable(std::function<void()> read_task, in Enable()112 auto read_task = Delegate::GetInstance()->read_task; in AppendNewRecord() local
172 auto read_task = [&last_value_read] { in TEST_F() local
257 let read_task = read_events(event, signal_wait, &ex); in event() localVariable
1049 let read_task = rx_source in canceled_before_completion() localVariable