Struct runa_core::events::aggregate::Sender

pub struct Sender<E> { /* private fields */ }

A sender for the aggregate event source.

The type parameter E is not the event type, it represents the internal state of the event source. It can be seen as an aggregate of the actual event type.

Implementations

impl<E> Sender<E>

pub fn new() -> Self

Create a new sender for a aggregate event source

impl<E: Default> Sender<E>

pub fn new_receiver(&self) -> Receiver<E>

Creata a new receiver for this sender

impl<E> Sender<E>

pub fn send<I: Clone>(&self, event: I)where E: Extend<I>,

Send an event to all receivers

Trait Implementations

impl<E: Debug> Debug for Sender<E>

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

Formats the value using the given formatter.

impl<E> Default for Sender<E>

fn default() -> Self

Returns the “default value” for a type.

impl<E: Iterator + Default + 'static> EventSource<<E as Iterator>::Item> for Sender<E>

type Source = impl Stream<Item = <E as Iterator>::Item> + FusedStream + Unpin

Type of event stream you get from this event source.

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

Get a stream of events from the event source.