Lines Matching refs:rx
29 let mut rx = task::spawn(rx1.merge(rx2)); in merge_async_streams() localVariable
31 assert_eq!(rx.size_hint(), (0, None)); in merge_async_streams()
33 assert_pending!(rx.poll_next()); in merge_async_streams()
37 assert!(rx.is_woken()); in merge_async_streams()
38 assert_eq!(Some(1), assert_ready!(rx.poll_next())); in merge_async_streams()
40 assert_pending!(rx.poll_next()); in merge_async_streams()
43 assert!(rx.is_woken()); in merge_async_streams()
44 assert_eq!(Some(2), assert_ready!(rx.poll_next())); in merge_async_streams()
45 assert_pending!(rx.poll_next()); in merge_async_streams()
48 assert!(rx.is_woken()); in merge_async_streams()
49 assert_pending!(rx.poll_next()); in merge_async_streams()
52 assert!(rx.is_woken()); in merge_async_streams()
53 assert_eq!(Some(3), assert_ready!(rx.poll_next())); in merge_async_streams()
54 assert_pending!(rx.poll_next()); in merge_async_streams()
57 assert!(rx.is_woken()); in merge_async_streams()
58 assert_eq!(None, assert_ready!(rx.poll_next())); in merge_async_streams()