Lines Matching refs:spawn
31 let mut rx = task::spawn(rx); in send_recv()
54 let mut rx = task::spawn(rx); in close_tx()
75 let mut tx = task::spawn(tx); in close_rx()
92 tokio::spawn(async move { in async_rx_closed()
103 let mut rx = task::spawn(rx); in explicit_close_poll()
114 let mut tx = task::spawn(tx); in explicit_close_poll()
115 let mut rx = task::spawn(rx); in explicit_close_poll()
130 let mut tx = task::spawn(tx); in explicit_close_poll()
131 let mut rx = task::spawn(rx); in explicit_close_poll()
158 let mut tx = task::spawn(tx); in explicit_close_try_recv()
175 let mut rx = task::spawn(rx); in close_try_recv_poll()
208 let mut tx_task = task::spawn(()); in drops_tasks()
209 let mut rx_task = task::spawn(()); in drops_tasks()
225 let mut task1 = task::spawn(()); in receiver_changes_task()
226 let mut task2 = task::spawn(()); in receiver_changes_task()
250 let mut task1 = task::spawn(()); in sender_changes_task()
251 let mut task2 = task::spawn(()); in sender_changes_task()