2 use futures::executor::{block_on, block_on_stream};
21     block_on(tx.send(1)).unwrap();  in send_recv()
23     let v: Vec<_> = block_on(rx.collect());  in send_recv()
30     block_on(poll_fn(move |cx| {  in send_recv_no_buffer()
69     block_on(tx1.send(1)).unwrap();  in send_shared_recv()
72     block_on(tx2.send(2)).unwrap();  in send_shared_recv()
81         block_on(tx.send(1)).unwrap();  in send_recv_threads()
84     let v: Vec<_> = block_on(rx.take(1).collect());  in send_recv_threads()
95         block_on(tx.send(1)).unwrap();  in send_recv_threads_no_capacity()
96         block_on(tx.send(2)).unwrap();  in send_recv_threads_no_capacity()
99     let v: Vec<_> = block_on(rx.collect());  in send_recv_threads_no_capacity()
110     block_on(poll_fn(move |cx| {  in recv_close_gets_none()
128     block_on(poll_fn(move |cx| {  in tx_close_gets_none()
208         let result: Vec<_> = block_on(rx.collect());  in stress_shared_unbounded()
237         let result: Vec<_> = block_on(rx.collect());  in stress_shared_bounded_hard()
249                 block_on(tx.send(1)).unwrap();  in stress_shared_bounded_hard()
283                         let item = block_on(rx.next());  in stress_receiver_multi_task_bounded_hard()
316         block_on(tx.send(i)).unwrap();  in stress_receiver_multi_task_bounded_hard()
334             block_on(send_one_two_three(tx));  in stress_drop_sender()
340         let v: Vec<_> = block_on(list().collect());  in stress_drop_sender()
411                 block_on(stress_poll_ready_sender(sender, AMT))  in stress_poll_ready()
416         let result: Vec<_> = block_on(rx.collect());  in stress_poll_ready()
445     let result: Vec<_> = block_on(rx.collect());  in try_send_1()
463         block_on(poll_fn(|cx| {  in try_send_2()
469         block_on(tx.send("goodbye")).unwrap();  in try_send_2()
472     let _ = block_on(readyrx);  in try_send_2()
598     block_on(tx.send(1)).unwrap();  in send_backpressure()
604     let item = block_on(rx.next()).unwrap();  in send_backpressure()
609     let item = block_on(rx.next()).unwrap();  in send_backpressure()
620     block_on(tx1.send(1)).unwrap();  in send_backpressure_multi_senders()
626     let item = block_on(rx.next()).unwrap();  in send_backpressure_multi_senders()
631     let item = block_on(rx.next()).unwrap();  in send_backpressure_multi_senders()