Struct MultiplexingSubscription

pub struct MultiplexingSubscription<Runtime, T>
where
    T: Async,
    Runtime: HasChannelTypes + HasMutex,
{
    pub stream_senders: Arc<MutexOf<Runtime, Option<Vec<<Runtime as HasChannelTypes>::Sender<T>>>>>,
}

Fields

stream_senders: Arc<MutexOf<Runtime, Option<Vec<<Runtime as HasChannelTypes>::Sender<T>>>>>

Trait Implementations

impl<Runtime, T> Clone for MultiplexingSubscription<Runtime, T>

where T: Async, Runtime: HasChannelTypes + HasMutex + HasStreamType<Stream<T> = Pin<Box<dyn Stream<Item = T> + Send + Sync + 'static>>>,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Runtime, T> Subscription for MultiplexingSubscription<Runtime, T>

where T: Async, Runtime: HasMutex + CanCreateChannels + CanStreamReceiver + HasBoxedStreamType,

type Item = T

The item that is yielded in the Streams returned from subscribe.

fn subscribe<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Option<Pin<Box<dyn Stream<Item = T> + Send + Sync + 'static>>>> + Send + 'async_trait>>

where T: Async, Self: 'async_trait, 'life0: 'async_trait,

If the subscription is still active, returns a new single consumer Stream which would produce a stream of items that are produced after the method is called.