Trait StreamShareReplayExt 

pub trait StreamShareReplayExt: Stream + Sized
where
    Self: Send + 'static,
    Self::Item: Clone + Send + 'static,
{
    // Provided methods
    fn share_replay(
        self,
        buffer_size: usize,
        capacity: usize,
    ) -> ShareReplayStream<Self> { ... }
    fn share_replay_overflow(
        self,
        buffer_size: usize,
        capacity: usize,
    ) -> ShareReplayStream<Self> { ... }
    fn share_replay_latest(self) -> ShareReplayStream<Self> { ... }
}

Provided Methods

fn share_replay( self, buffer_size: usize, capacity: usize, ) -> ShareReplayStream<Self>

fn share_replay_overflow( self, buffer_size: usize, capacity: usize, ) -> ShareReplayStream<Self>

Like share_replay(), but uses overflow mode to drop oldest queued values when full.

Replay for late subscribers remains bounded by buffer_size.

fn share_replay_latest(self) -> ShareReplayStream<Self>

Replay + latest mode.

This is equivalent to share_replay_overflow(1, 1).

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl<T> StreamShareReplayExt for T

where T: Stream + Sized + Send + 'static, T::Item: Clone + Send + 'static,