Lines Matching refs:tx
23 let (tx, mut rx) = mpsc::unbounded(); in unbounded_1_tx()
31 UnboundedSender::unbounded_send(&tx, i).unwrap(); in unbounded_1_tx()
44 let (tx, mut rx) = mpsc::unbounded(); in unbounded_100_tx()
46 let tx: Vec<_> = (0..100).map(|_| tx.clone()).collect(); in unbounded_100_tx() localVariable
50 for (i, x) in tx.iter().enumerate() { in unbounded_100_tx()
65 let (tx, mut rx) = mpsc::unbounded(); in unbounded_uncontended()
68 UnboundedSender::unbounded_send(&tx, i).expect("send"); in unbounded_uncontended()
77 tx: Sender<u32>, field
87 let mut tx = Pin::new(&mut this.tx); in poll_next() localVariable
89 ready!(tx.as_mut().poll_ready(cx)).unwrap(); in poll_next()
90 tx.as_mut().start_send(this.last + 1).unwrap(); in poll_next()
92 assert_eq!(Poll::Pending, tx.as_mut().poll_flush(cx)); in poll_next()
102 let (tx, mut rx) = mpsc::channel(0); in bounded_1_tx()
104 let mut tx = TestSender { tx, last: 0 }; in bounded_1_tx() localVariable
107 assert_eq!(Poll::Ready(Some(i + 1)), tx.poll_next_unpin(&mut cx)); in bounded_1_tx()
108 assert_eq!(Poll::Pending, tx.poll_next_unpin(&mut cx)); in bounded_1_tx()
120 let (tx, mut rx) = mpsc::channel(0); in bounded_100_tx()
122 let mut tx: Vec<_> = (0..100).map(|_| TestSender { tx: tx.clone(), last: 0 }).collect(); in bounded_100_tx() localVariable
125 for x in &mut tx { in bounded_100_tx()