Searched defs:recv_task (Results 1 – 4 of 4) sorted by relevance
103 let mut recv_task = spawn(recv.recv()); in close_sender_last() localVariable118 let mut recv_task = spawn(recv.recv()); in close_sender_not_last() localVariable137 let mut recv_task = spawn(recv.recv()); in close_sender_before_reserve() localVariable154 let mut recv_task = spawn(recv.recv()); in close_sender_after_pending_reserve() localVariable179 let mut recv_task = spawn(recv.recv()); in close_sender_after_successful_reserve() localVariable200 let mut recv_task = spawn(recv.recv()); in abort_send_after_pending_reserve() localVariable222 let mut recv_task = spawn(recv.recv()); in abort_send_after_successful_reserve() localVariable272 let mut recv_task = spawn(recv.recv()); in sink_send_then_flush() localVariable299 let mut recv_task = spawn(recv.recv()); in sink_send_then_close() localVariable316 let mut recv_task = spawn(recv.recv()); in sink_send_then_close() localVariable[all …]
159 ReceiveDatagramsUntilClosed recv_task(incoming_pair.first()); in ExpectSendAndReceive() local214 ReceiveDatagramsUntilClosed recv_task(datagram_pair.first()); in TEST() local
271 recv_task: AtomicWaker, field292 recv_task: AtomicWaker, field
106 pub recv_task: Option<Waker>, field