Struct remoc_obs::mpsc_replay::ReplayBuffer

pub struct ReplayBuffer<T, Codec = Default> { /* private fields */ }

A buffer that stores and replays values sent to a channel.

Values sent to the replay channel buffer are stored in an internal buffer. Multiple remote MPSC channels can be subscribed to the replay channel buffer and each channel will receive all values sent to the replay channel buffer, even the values that were received before it was subscribed.

Drop this to free the buffer and close all subscribed channels.

Implementations

impl<T, Codec> ReplayBuffer<T, Codec> where
    T: RemoteSend + Clone,
    Codec: Codec, 

pub fn new() -> Self

Creates a new replay channel buffer.

The buffer receives its values from the provided local MPSC channel receiver.

pub fn send(&self, value: T)

Sends a value to the replay channel buffer.

The value will be received by all currently subscribed receivers and all receivers that will be subscribed in the future.

pub fn subscribe<C, B>(&self, tx: Sender<T, C, B>) -> SubscriptionHandle where
    C: Codec,
    B: Size, 

Subscribes a remote MPSC channel to the replay channel buffer.

The channel will receive all values ever sent and future values that will be sent to the replay channel buffer.

The returned SubscriptionHandle can be used to query for errors that occur during sending to the channel.

Trait Implementations

impl<T, Codec> Debug for ReplayBuffer<T, Codec>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T, Codec> Default for ReplayBuffer<T, Codec> where
    T: RemoteSend + Clone,
    Codec: Codec, 

fn default() -> Self

Returns the “default value” for a type.

impl<T, Codec> Drop for ReplayBuffer<T, Codec>

fn drop(&mut self)

Executes the destructor for this type.