Struct sc_utils::notification::NotificationStream

pub struct NotificationStream<Payload, TK: TracingKeyStr> { /* private fields */ }

The receiving half of the notifications channel.

The NotificationStream entity stores the Hub so it can be used to add more subscriptions.

Implementations

impl<Payload, TK: TracingKeyStr> NotificationStream<Payload, TK>

pub fn channel() -> (NotificationSender<Payload>, Self)

Creates a new pair of receiver and sender of Payload notifications.

pub fn subscribe( &self, queue_size_warning: i64 ) -> NotificationReceiver<Payload>

Subscribe to a channel through which the generic payload can be received.

Trait Implementations

impl<Payload: Clone, TK: Clone + TracingKeyStr> Clone for NotificationStream<Payload, TK>

fn clone(&self) -> NotificationStream<Payload, TK>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.