Struct ntex_mqtt::v3::client::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) -> Selfwhere
    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, ControlMessage<Err>>,
    S: Service<ControlMessage<Err>, Response = ControlResult, 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.