• Home
  • Raw
  • Download

Lines Matching refs:rx

15     let (tx, rx) = mpsc::channel();  in join1()
17 assert_eq!(rx.recv(), Ok((1, 2))); in join1()
18 assert!(rx.recv().is_err()); in join1()
27 let (tx, rx) = mpsc::channel(); in join2()
29 assert!(rx.try_recv().is_err()); in join2()
31 assert!(rx.try_recv().is_err()); in join2()
33 assert_eq!(rx.recv(), Ok((1, 2))); in join2()
34 assert!(rx.recv().is_err()); in join2()
43 let (tx, rx) = mpsc::channel(); in join3()
45 assert!(rx.try_recv().is_err()); in join3()
47 assert_eq!(rx.recv(), Ok(1)); in join3()
48 assert!(rx.recv().is_err()); in join3()
58 let (tx, rx) = mpsc::channel(); in join4()
60 assert!(rx.try_recv().is_err()); in join4()
62 assert!(rx.recv().is_ok()); in join4()
64 assert!(rx.recv().is_err()); in join4()
74 let (tx, rx) = mpsc::channel(); in join5()
76 assert!(rx.try_recv().is_err()); in join5()
78 assert!(rx.try_recv().is_err()); in join5()
80 assert!(rx.try_recv().is_err()); in join5()
82 assert_eq!(rx.recv(), Ok(((1, 2), 3))); in join5()
83 assert!(rx.recv().is_err()); in join5()
92 let (tx, rx) = mpsc::channel(); in select1()
94 assert!(rx.try_recv().is_err()); in select1()
96 let (v, p2) = rx.recv().unwrap().into_inner(); in select1()
98 assert!(rx.recv().is_err()); in select1()
100 let (tx, rx) = mpsc::channel(); in select1()
103 assert_eq!(rx.recv(), Ok(2)); in select1()
104 assert!(rx.recv().is_err()); in select1()
113 let (tx, rx) = mpsc::channel(); in select2()
115 assert!(rx.try_recv().is_err()); in select2()
117 let (v, p2) = rx.recv().unwrap(); in select2()
119 assert!(rx.recv().is_err()); in select2()
121 let (tx, rx) = mpsc::channel(); in select2()
124 assert_eq!(rx.recv(), Ok(2)); in select2()
125 assert!(rx.recv().is_err()); in select2()
134 let (tx, rx) = mpsc::channel(); in select3()
136 assert!(rx.try_recv().is_err()); in select3()
138 let (v, p2) = rx.recv().unwrap(); in select3()
140 assert!(rx.recv().is_err()); in select3()
142 let (tx, rx) = mpsc::channel(); in select3()
145 assert_eq!(rx.recv(), Ok(2)); in select3()
146 assert!(rx.recv().is_err()); in select3()
155 let (tx, rx) = mpsc::channel::<oneshot::Sender<i32>>(); in select4()
158 for c in rx { in select4()