Skip to content

Commit dda65cb

Browse files
committed
Start throttle measurement before initialisation
1 parent 90c67c2 commit dda65cb

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/stream/stream/mod.rs

+2-1
Original file line numberDiff line numberDiff line change
@@ -327,6 +327,8 @@ extension_trait! {
327327
use async_std::stream;
328328
use std::time::{Duration, Instant};
329329
330+
let start = Instant::now();
331+
330332
// emit value every 5 milliseconds
331333
let s = stream::interval(Duration::from_millis(5))
332334
.enumerate()
@@ -335,7 +337,6 @@ extension_trait! {
335337
// throttle for 10 milliseconds
336338
let mut s = s.throttle(Duration::from_millis(10));
337339
338-
let start = Instant::now();
339340
assert_eq!(s.next().await, Some((0, ())));
340341
let duration_ms = start.elapsed().as_millis();
341342
assert!(duration_ms >= 5);

0 commit comments

Comments
 (0)