Lines Matching refs:mpsc
5 use std::sync::mpsc; in map_ok()
9 let (tx1, rx1) = mpsc::channel::<()>(); in map_ok()
10 let (tx2, rx2) = mpsc::channel::<()>(); in map_ok()
27 use std::sync::mpsc; in map_err()
31 let (tx1, rx1) = mpsc::channel::<()>(); in map_err()
32 let (tx2, rx2) = mpsc::channel::<()>(); in map_err()
71 use std::sync::mpsc; in then_drops_eagerly()
74 let (tx1, rx1) = mpsc::channel::<()>(); in then_drops_eagerly()
75 let (tx2, rx2) = mpsc::channel::<()>(); in then_drops_eagerly()
85 assert_eq!(Err(mpsc::TryRecvError::Empty), rx2.try_recv()); in then_drops_eagerly()
95 use std::sync::mpsc; in and_then_drops_eagerly()
98 let (tx1, rx1) = mpsc::channel::<()>(); in and_then_drops_eagerly()
99 let (tx2, rx2) = mpsc::channel::<()>(); in and_then_drops_eagerly()
109 assert_eq!(Err(mpsc::TryRecvError::Empty), rx2.try_recv()); in and_then_drops_eagerly()
119 use std::sync::mpsc; in or_else_drops_eagerly()
122 let (tx1, rx1) = mpsc::channel::<()>(); in or_else_drops_eagerly()
123 let (tx2, rx2) = mpsc::channel::<()>(); in or_else_drops_eagerly()
133 assert_eq!(Err(mpsc::TryRecvError::Empty), rx2.try_recv()); in or_else_drops_eagerly()