1 #![cfg(all(feature = "time", feature = "sync", feature = "io-util"))]
7 use futures::stream;
9 async fn maybe_sleep(idx: i32) -> i32 {  in maybe_sleep()
16 fn ms(n: u64) -> Duration {  in ms()
24     // Items 2 and 4 time out. If we run the stream until it completes,  in basic_usage()
29     let stream = stream::iter(1..=4).then(maybe_sleep).timeout(ms(100));  in basic_usage()  localVariable
30     let mut stream = task::spawn(stream);  in basic_usage()  localVariable
33     assert_ready_eq!(stream.poll_next(), Some(Ok(1)));  in basic_usage()
35     // Second item is delayed 200ms, times out after 100ms  in basic_usage()
36     assert_pending!(stream.poll_next());  in basic_usage()
39     let v = assert_ready!(stream.poll_next());  in basic_usage()
42     assert_pending!(stream.poll_next());  in basic_usage()
45     assert_ready_eq!(stream.poll_next(), Some(Ok(2)));  in basic_usage()
48     assert_ready_eq!(stream.poll_next(), Some(Ok(3)));  in basic_usage()
50     // Fourth item is delayed 200ms, times out after 100ms  in basic_usage()
51     assert_pending!(stream.poll_next());  in basic_usage()
54     assert_pending!(stream.poll_next()); // nothing ready yet  in basic_usage()
57     let v = assert_ready!(stream.poll_next());  in basic_usage()
61     assert_ready_eq!(stream.poll_next(), Some(Ok(4)));  in basic_usage()
64     assert_ready_eq!(stream.poll_next(), None);  in basic_usage()
71     let stream = stream::iter(1..=3).then(maybe_sleep).timeout(ms(50));  in return_elapsed_errors_only_once()  localVariable
72     let mut stream = task::spawn(stream);  in return_elapsed_errors_only_once()  localVariable
75     assert_ready_eq!(stream.poll_next(), Some(Ok(1)));  in return_elapsed_errors_only_once()
77     // Second item is delayed 200ms, times out after 50ms. Only one `Elapsed`  in return_elapsed_errors_only_once()
79     assert_pending!(stream.poll_next());  in return_elapsed_errors_only_once()
82     let v = assert_ready!(stream.poll_next());  in return_elapsed_errors_only_once()
87     assert_pending!(stream.poll_next());  in return_elapsed_errors_only_once()
90     assert_ready_eq!(stream.poll_next(), Some(Ok(2)));  in return_elapsed_errors_only_once()
91     assert_ready_eq!(stream.poll_next(), Some(Ok(3)));  in return_elapsed_errors_only_once()
94     assert_ready_eq!(stream.poll_next(), None);  in return_elapsed_errors_only_once()
99     let stream = stream::iter(vec![1, 3, 5])  in no_timeouts()  localVariable
103     let mut stream = task::spawn(stream);  in no_timeouts()  localVariable
105     assert_ready_eq!(stream.poll_next(), Some(Ok(1)));  in no_timeouts()
106     assert_ready_eq!(stream.poll_next(), Some(Ok(3)));  in no_timeouts()
107     assert_ready_eq!(stream.poll_next(), Some(Ok(5)));  in no_timeouts()
108     assert_ready_eq!(stream.poll_next(), None);  in no_timeouts()