Struct ripb::Subscriber

pub struct Subscriber { /* fields omitted */ }

A subscriber to a Bus.

Subscribers are created with the method [Bus.create_subscriber]

Register new callbacks with the [on_message] method, callback will live until the subscriber is dropped. If you need more control on callback lifecycle use [on_message_with_token] that will give you a SubscriptionToken you can use to [unsubscribe] a callback.

Methods

impl Subscriber

pub fn on_message<F, M>(&self, callback: F) -> Result<(), DeadBusError> where
    F: Fn(&M) + Send + 'static,
    M: Message + 'static, 

Register a new callback to be called each time a message of the given type is published on the bus, callback lives as until the Subscriber is dropped

pub fn on_message_with_token<F, M>(
    &self,
    callback: F
) -> Result<SubscriptionToken, DeadBusError> where
    F: Fn(&M) + Send + 'static,
    M: Message + 'static, 

Register a new callback to be called each time a message of the given type is published on the bus, callback lives as until the SubscriptionToken is dropped, unsubscribe is called on it or the Subscriber is dropped

Trait Implementations

impl Drop for Subscriber

fn drop(&mut self)

Executes the destructor for this type.