aboutsummaryrefslogtreecommitdiff
path: root/tests/time_throttle.rs
diff options
context:
space:
mode:
Diffstat (limited to 'tests/time_throttle.rs')
-rw-r--r--tests/time_throttle.rs28
1 files changed, 0 insertions, 28 deletions
diff --git a/tests/time_throttle.rs b/tests/time_throttle.rs
deleted file mode 100644
index c886319..0000000
--- a/tests/time_throttle.rs
+++ /dev/null
@@ -1,28 +0,0 @@
-#![warn(rust_2018_idioms)]
-#![cfg(feature = "full")]
-
-use tokio::stream::StreamExt;
-use tokio::time;
-use tokio_test::*;
-
-use std::time::Duration;
-
-#[tokio::test]
-async fn usage() {
- time::pause();
-
- let mut stream = task::spawn(futures::stream::repeat(()).throttle(Duration::from_millis(100)));
-
- 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());
-}