Struct workflow_core::channel::Multiplexer

pub struct Multiplexer<T>where
    T: Clone + Send + Sync + 'static,{
    pub channels: Arc<Mutex<HashMap<Id, Sender<T>>>>,
    /* private fields */
}

A simple channel Multiplexer that broadcasts to multiple registered receivers.

Fields

channels: Arc<Mutex<HashMap<Id, Sender<T>>>>

Implementations

impl<T> Multiplexer<T>where T: Clone + Send + Sync + 'static,

pub fn new() -> Multiplexer<T>

pub fn register_event_channel(&self) -> (Id, Sender<T>, Receiver<T>)

pub fn unregister_event_channel(&self, id: Id)

pub async fn broadcast(&self, event: T) -> Result<(), ChannelError<T>>

Trait Implementations

impl<T> Clone for Multiplexer<T>where T: Clone + Send + Sync + 'static + Clone,

fn clone(&self) -> Multiplexer<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T> Default for Multiplexer<T>where T: Clone + Send + Sync + 'static,

fn default() -> Self

Returns the “default value” for a type.