Struct ntex_mqtt::v3::client::ClientRouter

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

Mqtt client with routing capabilities

Implementations

impl<Io, Err, PErr> ClientRouter<Io, Err, PErr> where
    Io: AsyncRead + AsyncWrite + Unpin + 'static,
    Err: From<PErr> + 'static,
    PErr: 'static, 

pub fn resource<T, F, S>(self, address: T, service: F) -> Self where
    T: IntoPattern,
    F: IntoService<S>,
    S: Service<Request = 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> + 'static,
    S: Service<Request = ControlMessage<Err>, Response = ControlResult, Error = Err> + 'static, 

Run client and handle control messages