chore: update tokio to v1.0

Author: 90-008

futures/Cargo.toml

@@ -12,6 +12,7 @@ categories = ["gui"]
 
 [features]
 thread-pool = ["futures/thread-pool"]
+tokio = ["tokio_new", "async-stream"]
 
 [dependencies]
 log = "0.4"
@@ -25,10 +26,15 @@ version = "0.2"
 optional = true
 features = ["rt-core", "rt-threaded", "time", "stream"]
 
-[target.'cfg(not(target_arch = "wasm32"))'.dependencies.tokio]
-version = "0.3"
+[target.'cfg(not(target_arch = "wasm32"))'.dependencies.tokio_new]
+package = "tokio"
+version = "1.0"
+optional = true
+features = ["rt-multi-thread", "time"]
+
+[target.'cfg(not(target_arch = "wasm32"))'.dependencies.async-stream]
+version = "0.3.0"
 optional = true
-features = ["rt-multi-thread", "time", "stream"]
 
 [target.'cfg(not(target_arch = "wasm32"))'.dependencies.async-std]
 version = "1.0"

futures/src/executor/tokio.rs

@@ -1,6 +1,7 @@
 use crate::Executor;
 
 use futures::Future;
+use tokio_new as tokio;
 
 /// A `tokio` runtime.
 #[cfg_attr(docsrs, doc(cfg(feature = "tokio")))]

futures/src/time.rs

@@ -62,11 +62,25 @@ where
     ) -> futures::stream::BoxStream<'static, Self::Output> {
         use futures::stream::StreamExt;
 
+        #[cfg(feature = "tokio")]
+        use tokio_new as tokio;
         #[cfg(feature = "tokio_old")]
         use tokio_old as tokio;
 
         let start = tokio::time::Instant::now() + self.0;
 
+        #[cfg(feature = "tokio")]
+        {
+            let stream = async_stream::stream! {
+               let mut interval = tokio::time::interval_at(start, self.0);
+               loop {
+                   yield interval.tick().await;
+               }
+            };
+
+            stream.map(|_| std::time::Instant::now()).boxed()
+        }
+        #[cfg(feature = "tokio_old")]
         tokio::time::interval_at(start, self.0)
             .map(|_| std::time::Instant::now())
             .boxed()