Home
last modified time | relevance | path

Searched defs:recv_task (Results 1 – 2 of 2) sorted by relevance

/external/rust/crates/tokio-util/tests/
Dmpsc.rs77 let mut recv_task = spawn(recv.recv()); in close_sender_last() localVariable
92 let mut recv_task = spawn(recv.recv()); in close_sender_not_last() localVariable
111 let mut recv_task = spawn(recv.recv()); in close_sender_before_reserve() localVariable
128 let mut recv_task = spawn(recv.recv()); in close_sender_after_pending_reserve() localVariable
153 let mut recv_task = spawn(recv.recv()); in close_sender_after_successful_reserve() localVariable
174 let mut recv_task = spawn(recv.recv()); in abort_send_after_pending_reserve() localVariable
196 let mut recv_task = spawn(recv.recv()); in abort_send_after_successful_reserve() localVariable
/external/rust/crates/futures-channel/src/mpsc/
Dmod.rs270 recv_task: AtomicWaker, field
291 recv_task: AtomicWaker, field