324     use futures::channel::mpsc;  in mpsc_blocking_start_send()
333     let (mut tx, mut rx) = mpsc::channel::<i32>(0);  in mpsc_blocking_start_send()
424     use futures::channel::mpsc;  in with_propagates_poll_ready()
434     let (tx, mut rx) = mpsc::channel::<i32>(0);  in with_propagates_poll_ready()
435     let mut tx = tx.with(|item: i32| future::ok::<i32, mpsc::SendError>(item + 10));  in with_propagates_poll_ready()
489     use futures::channel::mpsc;  in with_implements_clone()
494     let (mut tx, rx) = mpsc::channel(5);  in with_implements_clone()
499             .with(|item| future::ok::<bool, mpsc::SendError>(item > 0));  in with_implements_clone()
503             .with(|item: &str| future::ok::<bool, mpsc::SendError>(item.len() > 5));  in with_implements_clone()
585     use futures::channel::mpsc;  in fanout_backpressure()
595     let (left_send, mut left_recv) = mpsc::channel(0);  in fanout_backpressure()
596     let (right_send, mut right_recv) = mpsc::channel(0);  in fanout_backpressure()
627     use futures::channel::mpsc;  in sink_map_err()
635         let (tx, _rx) = mpsc::channel(1);  in sink_map_err()
641     let tx = mpsc::channel(0).0;  in sink_map_err()
650     use futures::channel::mpsc;  in sink_unfold()
657         let (tx, mut rx) = mpsc::channel(1);  in sink_unfold()
688     use futures::channel::mpsc;  in err_into()
697     impl From<mpsc::SendError> for ErrIntoTest {  in err_into()
698         fn from(_: mpsc::SendError) -> Self {  in err_into()
705         let (tx, _rx) = mpsc::channel(1);  in err_into()
706         let mut tx: SinkErrInto<mpsc::Sender<()>, _, ErrIntoTest> = tx.sink_err_into();  in err_into()
711     let tx = mpsc::channel(0).0;  in err_into()