1 use futures::channel::mpsc;
14     let (mut sender, receiver) = mpsc::channel(1);  in smoke()
29         let (mut tx1, mut rx) = mpsc::channel(1);  in multiple_senders_disconnect()
51         let (mut tx1, mut rx) = mpsc::unbounded();  in multiple_senders_disconnect()
76         let (mut tx1, mut rx) = mpsc::channel(1);  in multiple_senders_close_channel()
92         let (tx1, mut rx) = mpsc::unbounded();  in multiple_senders_close_channel()
114         let (sender, receiver) = mpsc::unbounded();  in single_receiver_drop_closes_channel_and_drains()
133         let (mut sender, receiver) = mpsc::channel(1);  in single_receiver_drop_closes_channel_and_drains()
167         rx: mpsc::Receiver<Arc<()>>,  in stress_try_send_as_receiver_closes()
172         command_rx: mpsc::Receiver<TestRx>,  in stress_try_send_as_receiver_closes()
173         test_rx: Option<mpsc::Receiver<Arc<()>>>,  in stress_try_send_as_receiver_closes()
178         fn new() -> (TestTask, mpsc::Sender<TestRx>) {  in stress_try_send_as_receiver_closes()
179             let (command_tx, command_rx) = mpsc::channel::<TestRx>(0);  in stress_try_send_as_receiver_closes()
226         let (mut test_tx, rx) = mpsc::channel(0);  in stress_try_send_as_receiver_closes()