summaryrefslogtreecommitdiffstats
path: root/examples/game_of_life/src/time.rs
diff options
context:
space:
mode:
Diffstat (limited to 'examples/game_of_life/src/time.rs')
-rw-r--r--examples/game_of_life/src/time.rs34
1 files changed, 34 insertions, 0 deletions
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()
+ }
+}