From 810b445f8d2f429e9ad07625f9b67dba09783d7a Mon Sep 17 00:00:00 2001
From: Héctor Ramón Jiménez <hector0193@gmail.com>
Date: Fri, 14 Jan 2022 19:43:06 +0700
Subject: Rewrite `events` and `events_with` with a new `Runner` abstraction

---
 native/src/subscription/events.rs | 35 -----------------------------------
 1 file changed, 35 deletions(-)
 delete mode 100644 native/src/subscription/events.rs

(limited to 'native/src/subscription/events.rs')

diff --git a/native/src/subscription/events.rs b/native/src/subscription/events.rs
deleted file mode 100644
index ca143bb3..00000000
--- a/native/src/subscription/events.rs
+++ /dev/null
@@ -1,35 +0,0 @@
-use crate::event::{self, Event};
-use crate::subscription::{EventStream, Recipe};
-use crate::Hasher;
-use iced_futures::futures::future;
-use iced_futures::futures::StreamExt;
-use iced_futures::BoxStream;
-
-pub struct Events<Message> {
-    pub(super) f: fn(Event, event::Status) -> Option<Message>,
-}
-
-impl<Message> Recipe<Hasher, (Event, event::Status)> for Events<Message>
-where
-    Message: 'static + Send,
-{
-    type Output = Message;
-
-    fn hash(&self, state: &mut Hasher) {
-        use std::hash::Hash;
-
-        struct Marker;
-        std::any::TypeId::of::<Marker>().hash(state);
-        self.f.hash(state);
-    }
-
-    fn stream(
-        self: Box<Self>,
-        event_stream: EventStream,
-    ) -> BoxStream<Self::Output> {
-        let stream = event_stream.filter_map(move |(event, status)| {
-            future::ready((self.f)(event, status))
-        });
-        iced_futures::boxed_stream(stream)
-    }
-}
-- 
cgit