Implement `time::every` in `iced_futures`

3 files changed, 2 insertions, 39 deletions

diff --git a/examples/game_of_life/Cargo.toml b/examples/game_of_life/Cargo.toml
index 8855b3e8..413493ae 100644
--- a/examples/game_of_life/Cargo.toml
+++ b/examples/game_of_life/Cargo.toml
@@ -6,7 +6,5 @@ edition = "2018"
 publish = false
 
 [dependencies]
-iced = { path = "../..", features = ["async-std", "canvas", "debug"] }
-iced_native = { path = "../../native" }
-async-std = { version = "1.0", features = ["unstable"] }
+iced = { path = "../..", features = ["canvas", "tokio"] }
 itertools = "0.9"
diff --git a/examples/game_of_life/src/main.rs b/examples/game_of_life/src/main.rs
index 9fb4c3e7..5a58a8cb 100644
--- a/examples/game_of_life/src/main.rs
+++ b/examples/game_of_life/src/main.rs
@@ -1,14 +1,13 @@
 //! This example showcases an interactive version of the Game of Life, invented
 //! by John Conway. It leverages a `Canvas` together with other widgets.
 mod style;
-mod time;
 
 use grid::Grid;
 use iced::{
     button::{self, Button},
     executor,
     slider::{self, Slider},
-    Align, Application, Column, Command, Container, Element, Length, Row,
+    time, Align, Application, Column, Command, Container, Element, Length, Row,
     Settings, Subscription, Text,
 };
 use std::time::{Duration, Instant};
diff --git a/examples/game_of_life/src/time.rs b/examples/game_of_life/src/time.rs
deleted file mode 100644
index 7b475ecd..00000000
--- a/examples/game_of_life/src/time.rs
+++ /dev/null
@@ -1,34 +0,0 @@
-use iced::futures;
-
-pub fn every(
-    duration: std::time::Duration,
-) -> iced::Subscription<std::time::Instant> {
-    iced::Subscription::from_recipe(Every(duration))
-}
-
-struct Every(std::time::Duration);
-
-impl<H, I> iced_native::subscription::Recipe<H, I> for Every
-where
-    H: std::hash::Hasher,
-{
-    type Output = std::time::Instant;
-
-    fn hash(&self, state: &mut H) {
-        use std::hash::Hash;
-
-        std::any::TypeId::of::<Self>().hash(state);
-        self.0.hash(state);
-    }
-
-    fn stream(
-        self: Box<Self>,
-        _input: futures::stream::BoxStream<'static, I>,
-    ) -> futures::stream::BoxStream<'static, Self::Output> {
-        use futures::stream::StreamExt;
-
-        async_std::stream::interval(self.0)
-            .map(|_| std::time::Instant::now())
-            .boxed()
-    }
-}