diff options
author | 2020-11-12 02:22:22 +0100 | |
---|---|---|
committer | 2020-11-12 02:22:22 +0100 | |
commit | 69c50c851193348ed3aab746678741f3cdda9fb3 (patch) | |
tree | fe8fe23c2de55cbb3af21e0682a9a51121b2b357 /native/src/subscription | |
parent | 33d80b5a0b8b5b2837c99be2a152bdeb73ca60c8 (diff) | |
download | iced-69c50c851193348ed3aab746678741f3cdda9fb3.tar.gz iced-69c50c851193348ed3aab746678741f3cdda9fb3.tar.bz2 iced-69c50c851193348ed3aab746678741f3cdda9fb3.zip |
Introduce `event::Status` to `Subscription`
Diffstat (limited to 'native/src/subscription')
-rw-r--r-- | native/src/subscription/events.rs | 15 |
1 files changed, 8 insertions, 7 deletions
diff --git a/native/src/subscription/events.rs b/native/src/subscription/events.rs index a1ae6051..f689f3af 100644 --- a/native/src/subscription/events.rs +++ b/native/src/subscription/events.rs @@ -1,16 +1,15 @@ -use crate::{ - subscription::{EventStream, Recipe}, - Event, Hasher, -}; +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) -> Option<Message>, + pub(super) f: fn(Event, event::Status) -> Option<Message>, } -impl<Message> Recipe<Hasher, Event> for Events<Message> +impl<Message> Recipe<Hasher, (Event, event::Status)> for Events<Message> where Message: 'static + Send, { @@ -29,7 +28,9 @@ where event_stream: EventStream, ) -> BoxStream<Self::Output> { event_stream - .filter_map(move |event| future::ready((self.f)(event))) + .filter_map(move |(event, status)| { + future::ready((self.f)(event, status)) + }) .boxed() } } |