Rewrite `events` and `events_with` with a new `Runner` abstraction

1 files changed, 0 insertions, 35 deletions

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)
-    }
-}