Struct ntex_mqtt::v3::Client [−][src]
pub struct Client<Io> { /* fields omitted */ }
Expand description
Mqtt client
Implementations
Indicates whether there is already stored Session state
Configure mqtt resource for a specific topic
Run client with default control messages handler.
Default handler closes connection on any control message.
pub async fn start<F, S, E>(self, service: F) -> Result<(), MqttError<E>> where
E: 'static,
F: IntoService<S> + 'static,
S: Service<Request = ControlMessage, Response = ControlResult, Error = E> + 'static,
[src]
pub async fn start<F, S, E>(self, service: F) -> Result<(), MqttError<E>> where
E: 'static,
F: IntoService<S> + 'static,
S: Service<Request = ControlMessage, Response = ControlResult, Error = E> + 'static,
[src]Run client with provided control messages handler
Auto Trait Implementations
impl<Io> !RefUnwindSafe for Client<Io>
impl<Io> !UnwindSafe for Client<Io>