Struct sc_utils::notification::NotificationStream
source · pub struct NotificationStream<Payload, TK: TracingKeyStr> { /* private fields */ }Expand description
The receiving half of the notifications channel.
The NotificationStream entity stores the Hub so it can be
used to add more subscriptions.
Implementations§
source§impl<Payload, TK: TracingKeyStr> NotificationStream<Payload, TK>
impl<Payload, TK: TracingKeyStr> NotificationStream<Payload, TK>
sourcepub fn channel() -> (NotificationSender<Payload>, Self)
pub fn channel() -> (NotificationSender<Payload>, Self)
Creates a new pair of receiver and sender of Payload notifications.
sourcepub fn subscribe(
&self,
queue_size_warning: usize
) -> NotificationReceiver<Payload>
pub fn subscribe( &self, queue_size_warning: usize ) -> NotificationReceiver<Payload>
Subscribe to a channel through which the generic payload can be received.
Trait Implementations§
source§impl<Payload: Clone, TK: Clone + TracingKeyStr> Clone for NotificationStream<Payload, TK>
impl<Payload: Clone, TK: Clone + TracingKeyStr> Clone for NotificationStream<Payload, TK>
source§fn clone(&self) -> NotificationStream<Payload, TK>
fn clone(&self) -> NotificationStream<Payload, TK>
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreAuto Trait Implementations§
impl<Payload, TK> !RefUnwindSafe for NotificationStream<Payload, TK>
impl<Payload, TK> Send for NotificationStream<Payload, TK>where Payload: Send, TK: Send,
impl<Payload, TK> Sync for NotificationStream<Payload, TK>where Payload: Send, TK: Sync,
impl<Payload, TK> Unpin for NotificationStream<Payload, TK>where TK: Unpin,
impl<Payload, TK> !UnwindSafe for NotificationStream<Payload, TK>
Blanket Implementations§
source§impl<T> SaturatedConversion for T
impl<T> SaturatedConversion for T
source§fn saturated_from<T>(t: T) -> Selfwhere
Self: UniqueSaturatedFrom<T>,
fn saturated_from<T>(t: T) -> Selfwhere Self: UniqueSaturatedFrom<T>,
source§fn saturated_into<T>(self) -> Twhere
Self: UniqueSaturatedInto<T>,
fn saturated_into<T>(self) -> Twhere Self: UniqueSaturatedInto<T>,
Consume self to return an equivalent value of
T. Read moresource§impl<T, S> UniqueSaturatedInto<T> for Swhere
T: Bounded,
S: TryInto<T>,
impl<T, S> UniqueSaturatedInto<T> for Swhere T: Bounded, S: TryInto<T>,
source§fn unique_saturated_into(self) -> T
fn unique_saturated_into(self) -> T
Consume self to return an equivalent value of
T.