From 70f86f998b6db102d5b77f756750414efd53aa9e Mon Sep 17 00:00:00 2001
From: Héctor Ramón Jiménez <hector0193@gmail.com>
Date: Wed, 29 Apr 2020 08:25:42 +0200
Subject: Add `game_of_life` example

RIP John Conway
---
 examples/game_of_life/src/time.rs | 34 ++++++++++++++++++++++++++++++++++
 1 file changed, 34 insertions(+)
 create mode 100644 examples/game_of_life/src/time.rs

(limited to 'examples/game_of_life/src/time.rs')

diff --git a/examples/game_of_life/src/time.rs b/examples/game_of_life/src/time.rs
new file mode 100644
index 00000000..7b475ecd
--- /dev/null
+++ b/examples/game_of_life/src/time.rs
@@ -0,0 +1,34 @@
+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()
+    }
+}
-- 
cgit