diff options
author | 2024-06-11 20:22:44 +0200 | |
---|---|---|
committer | 2024-06-11 20:22:44 +0200 | |
commit | e6d0b3bda5042a1017a5944a5227c97e0ed6caf9 (patch) | |
tree | 916f837424c3baeacc1e0f43b02bc892a3445cbb /futures/src/subscription/tracker.rs | |
parent | bda01567d59c00e42e5a208ee6d9ec4153d5c195 (diff) | |
parent | 6ea7846d88915f8d820c5126d7757f1346234522 (diff) | |
download | iced-e6d0b3bda5042a1017a5944a5227c97e0ed6caf9.tar.gz iced-e6d0b3bda5042a1017a5944a5227c97e0ed6caf9.tar.bz2 iced-e6d0b3bda5042a1017a5944a5227c97e0ed6caf9.zip |
Merge pull request #2456 from iced-rs/window-id-in-event-subscriptions
Introduce `window::Id` to `Event` subscriptions
Diffstat (limited to '')
-rw-r--r-- | futures/src/subscription/tracker.rs | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/futures/src/subscription/tracker.rs b/futures/src/subscription/tracker.rs index 277a446b..f17e3ea3 100644 --- a/futures/src/subscription/tracker.rs +++ b/futures/src/subscription/tracker.rs @@ -1,5 +1,4 @@ -use crate::core::event::{self, Event}; -use crate::subscription::{Hasher, Recipe}; +use crate::subscription::{Event, Hasher, Recipe}; use crate::{BoxFuture, MaybeSend}; use futures::channel::mpsc; @@ -23,7 +22,7 @@ pub struct Tracker { #[derive(Debug)] pub struct Execution { _cancel: futures::channel::oneshot::Sender<()>, - listener: Option<futures::channel::mpsc::Sender<(Event, event::Status)>>, + listener: Option<futures::channel::mpsc::Sender<Event>>, } impl Tracker { @@ -139,12 +138,12 @@ impl Tracker { /// currently open. /// /// [`Recipe::stream`]: crate::subscription::Recipe::stream - pub fn broadcast(&mut self, event: Event, status: event::Status) { + pub fn broadcast(&mut self, event: Event) { self.subscriptions .values_mut() .filter_map(|connection| connection.listener.as_mut()) .for_each(|listener| { - if let Err(error) = listener.try_send((event.clone(), status)) { + if let Err(error) = listener.try_send(event.clone()) { log::warn!( "Error sending event to subscription: {error:?}" ); |