2 use futures::executor::block_on;
17         while let Ok(()) = block_on(sender.send(42)) {}  in smoke()
21     block_on(receiver.take(3).for_each(|_| futures::future::ready(())));  in smoke()
36         block_on(tx3.close()).unwrap();  in multiple_senders_disconnect()
42         block_on(tx4.send(5)).unwrap();  in multiple_senders_disconnect()
43         assert_eq!(block_on(rx.next()), Some(5));  in multiple_senders_disconnect()
47         assert_eq!(block_on(rx.next()), None);  in multiple_senders_disconnect()
58         block_on(tx3.close()).unwrap();  in multiple_senders_disconnect()
64         block_on(tx4.send(5)).unwrap();  in multiple_senders_disconnect()
65         assert_eq!(block_on(rx.next()), Some(5));  in multiple_senders_disconnect()
69         assert_eq!(block_on(rx.next()), None);  in multiple_senders_disconnect()
85         let err = block_on(tx2.send(5)).unwrap_err();  in multiple_senders_close_channel()
88         assert_eq!(block_on(rx.next()), None);  in multiple_senders_close_channel()
101         let err = block_on(tx2.send(5)).unwrap_err();  in multiple_senders_close_channel()
104         assert_eq!(block_on(rx.next()), None);  in multiple_senders_close_channel()
224     let bg = thread::spawn(move || block_on(f));  in stress_try_send_as_receiver_closes()