Struct ClientRouter

pub struct ClientRouter<Err, PErr> { /* private fields */ }

Mqtt client with routing capabilities

Implementations

impl<Err, PErr> ClientRouter<Err, PErr>

where Err: From<PErr> + 'static, PErr: 'static,

pub fn resource<T, F, S>(self, address: T, service: F) -> Self

where T: IntoPattern, F: IntoService<S, Publish>, S: Service<Publish, Response = (), Error = PErr> + 'static,

Configure mqtt resource for a specific topic

pub async fn start_default(self)

Run client with default control messages handler

pub async fn start<F, S>(self, service: F) -> Result<(), MqttError<Err>>

where F: IntoService<S, Control<Err>>, S: Service<Control<Err>, Response = ControlAck, Error = Err> + 'static,

Run client and handle control messages

Trait Implementations

impl<Err, PErr> Debug for ClientRouter<Err, PErr>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.