Struct rumqtt::MqttCallback

pub struct MqttCallback {
    pub on_message: Option<Arc<Box<Fn(Message) + Send + Sync>>>,
    pub on_publish: Option<Arc<Box<Fn(Message) + Send + Sync>>>,
}

Fields

on_message: Option<Arc<Box<Fn(Message) + Send + Sync>>>

on_publish: Option<Arc<Box<Fn(Message) + Send + Sync>>>

Methods

impl MqttCallback

fn new() -> Self

fn on_message<F>(self, cb: F) -> Self where
    F: Fn(Message) + Sync + Send + 'static, 

fn on_publish<F>(self, cb: F) -> Self where
    F: Fn(Message) + Sync + Send + 'static,