Struct runa_core::events::broadcast::Ring

pub struct Ring<E>(_, _);

An event source implementation based on the [async_broadcast] channels.

Like Broadcast, except when the internal queue is full, the oldest event will be dropped.

This event source is mpmc, so it can be cloned, enabling multiple sender to send at the same time

Implementations

impl<E> Ring<E>

pub fn new(capacity: usize) -> Self

Create a new ring broadcast event source

pub fn set_capacity(&mut self, capacity: usize)

Change the number of events the ring event source can hold

pub fn sender_count(&self) -> usize

Return the number of sender associated with this event source

impl<E: Clone> Ring<E>

pub fn broadcast(&self, msg: E)

Send a new event to all receivers

Trait Implementations

impl<E> Clone for Ring<E>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<E: Debug> Debug for Ring<E>

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

Formats the value using the given formatter.

impl<E: Clone + 'static> EventSource<E> for Ring<E>

type Source = Receiver<E>

Type of event stream you get from this event source.

fn subscribe(&self) -> Self::Source

Get a stream of events from the event source.