Struct EventSubscribers 

pub struct EventSubscribers<TEventMessage>
where
    TEventMessage: 'static + SceneMessage,
{ /* private fields */ }

Stores the subscribers for an event stream, and forwards events as needed

Implementations

impl<TEventMessage> EventSubscribers<TEventMessage>

where TEventMessage: 'static + SceneMessage,

pub fn new() -> Self

Creates a new set of event subscribers

pub fn subscribe( &mut self, context: &SceneContext, target: impl Into<StreamTarget>, )

Subscribes a subprogram to the events sent by this object

pub fn add_target(&mut self, output_sink: OutputSink<TEventMessage>)

Adds a target output sink to the list of subscribers for this object

This sink cannot be unsubscribed from the events, but this can be used to send to other streams where the target is not identified by a subprogram ID

pub async fn send_round_robin( &mut self, message: TEventMessage, ) -> Result<(), TEventMessage>

Sends a message to a single subscriber, returning Ok(()) if the message is delivered, otherwise returning an error that preserves the original message

Subscribers are sent to in a round-robin fashion

impl<TEventMessage> EventSubscribers<TEventMessage>

where TEventMessage: 'static + Clone + SceneMessage,

pub async fn send(&mut self, message: TEventMessage) -> bool

Sends a message to the subscribers to this object

Returns true if the message is sent to at least one subscriber, or false if there are no subscribers