Struct MultiSubscription 

pub struct MultiSubscription { /* private fields */ }

Implementations

impl MultiSubscription

pub fn unregistered() -> Self

Examples found in repository

examples/simple.rs (line 79)

    fn new() -> Self {
        let mut multi_sub = MultiSubscription::unregistered();
        multi_sub.add::<TestMsg0>().add::<TestMsg1>();

        Self { sub: multi_sub }
    }

pub fn add<M: Message>(&mut self) -> &mut Self

Examples found in repository

examples/simple.rs (line 80)

    fn new() -> Self {
        let mut multi_sub = MultiSubscription::unregistered();
        multi_sub.add::<TestMsg0>().add::<TestMsg1>();

        Self { sub: multi_sub }
    }

Trait Implementations

impl ErasedSubscription for MultiSubscription

fn message_broker(&self) -> Option<Arc<dyn MessageBroker>>

Returns a message broker which sends messages to this subscription.

fn is_registered(&self) -> bool

Returns if the subscription is registered.

fn is_active(&self) -> bool

Returns if the subscription is active.

fn register( &mut self, msg_broker: Arc<dyn MessageBroker>, ) -> Result<(), SubscriptionError>

Registers the subscription in the given message broker.

fn unregister(&mut self) -> Result<(), SubscriptionError>

Unregisters the subscription in the given message broker.

fn activate(&self) -> Result<(), SubscriptionError>

Activates the subscription if it was deactivated before.

fn deactivate(&self) -> Result<(), SubscriptionError>

Dectivates the subscription, in other words temporary makes it stop receiving messages.

fn recv_message(&self) -> Option<Arc<dyn Message>>

Receives one message if there is any.

fn message_iter(&self) -> MessageIter<'_>

Returns an iterator that will attempt to yield all pending messages.

fn process_messages<'f>(&self, f: Box<dyn ErasedMessageHandler + 'f>)

Processes all pending messages by calling the given function on each one.