diff options
| author |  Yusuf Bera Ertan <y.bera003.06@protonmail.com> | 2021-01-04 22:58:39 +0300 |
|---|---|---|
| committer |  Héctor Ramón Jiménez <hector0193@gmail.com> | 2021-01-04 23:20:21 +0100 |
| commit | 50452e62b4df458d676fc95361b04ef2dd83aebf (patch) | |
| tree | a8988fe89505da6675e846938080d8563157927d /futures/src | |
| parent | 2665860b4ddff773bca9959fe828776ecb03ab7d (diff) | |
| download | iced-50452e62b4df458d676fc95361b04ef2dd83aebf.tar.gz iced-50452e62b4df458d676fc95361b04ef2dd83aebf.tar.bz2 iced-50452e62b4df458d676fc95361b04ef2dd83aebf.zip | |
Update `tokio` to `1.0`
Diffstat (limited to 'futures/src')
| -rw-r--r-- | futures/src/time.rs | 18 |
1 files changed, 15 insertions, 3 deletions
diff --git a/futures/src/time.rs b/futures/src/time.rs index 5e9ea436..7458af06 100644 --- a/futures/src/time.rs +++ b/futures/src/time.rs @@ -67,8 +67,20 @@ where let start = tokio::time::Instant::now() + self.0; - tokio::time::interval_at(start, self.0) - .map(|_| std::time::Instant::now()) - .boxed() + let stream = { + #[cfg(feature = "tokio")] + { + futures::stream::unfold( + tokio::time::interval_at(start, self.0), + |mut interval| async move { + Some((interval.tick().await, interval)) + }, + ) + } + #[cfg(feature = "tokio_old")] + tokio::time::interval_at(start, self.0) + }; + + stream.map(|_| std::time::Instant::now()).boxed() } } |