Lines Matching refs:spawn
6 use tokio_test::task::spawn;
15 let mut t = spawn(rx.changed()); in single_rx_recv()
21 let mut t = spawn(rx.changed()); in single_rx_recv()
33 let mut t = spawn(rx.changed()); in single_rx_recv()
50 let mut t1 = spawn(rx1.changed()); in multi_rx()
51 let mut t2 = spawn(rx2.changed()); in multi_rx()
59 let mut t2 = spawn(rx2.changed()); in multi_rx()
62 let mut t1 = spawn(rx1.changed()); in multi_rx()
77 let mut t1 = spawn(rx1.changed()); in multi_rx()
96 let mut t1 = spawn(rx1.changed()); in multi_rx()
97 let mut t2 = spawn(rx2.changed()); in multi_rx()
119 let mut t1 = spawn(rx.changed()); in rx_observes_final_value()
131 let mut t1 = spawn(rx.changed()); in rx_observes_final_value()
137 let mut t1 = spawn(rx.changed()); in rx_observes_final_value()
150 let mut t1 = spawn(rx.changed()); in rx_observes_final_value()
161 let mut t = spawn(tx.closed()); in poll_close()