diff options
Diffstat (limited to 'third_party/rust/tokio/tests/time_throttle.rs')
-rw-r--r-- | third_party/rust/tokio/tests/time_throttle.rs | 30 |
1 files changed, 30 insertions, 0 deletions
diff --git a/third_party/rust/tokio/tests/time_throttle.rs b/third_party/rust/tokio/tests/time_throttle.rs new file mode 100644 index 0000000000..7102d17343 --- /dev/null +++ b/third_party/rust/tokio/tests/time_throttle.rs @@ -0,0 +1,30 @@ +#![warn(rust_2018_idioms)] +#![cfg(feature = "full")] + +use tokio::time::{self, throttle}; +use tokio_test::*; + +use std::time::Duration; + +#[tokio::test] +async fn usage() { + time::pause(); + + let mut stream = task::spawn(throttle( + Duration::from_millis(100), + futures::stream::repeat(()), + )); + + assert_ready!(stream.poll_next()); + assert_pending!(stream.poll_next()); + + time::advance(Duration::from_millis(90)).await; + + assert_pending!(stream.poll_next()); + + time::advance(Duration::from_millis(101)).await; + + assert!(stream.is_woken()); + + assert_ready!(stream.poll_next()); +} |