Struct actix_mqtt::client::ServiceBuilder

pub struct ServiceBuilder<Io, St, C: Service> { /* fields omitted */ }

Methods

impl<Io, St, C> ServiceBuilder<Io, St, C> where
    St: 'static,
    Io: AsyncRead + AsyncWrite + 'static,
    C: Service<Request = ConnectAck<Io>, Response = ConnectAckResult<Io, St>> + 'static,
    C::Error: 'static, 

pub fn subscribe<F, Srv>(self, subscribe: F) -> Self where
    F: IntoNewService<Srv>,
    Srv: NewService<Config = St, Request = Subscribe<St>, Response = SubscribeResult, InitError = C::Error, Error = C::Error> + 'static,
    Srv::Service: 'static, 

Service to execute for subscribe packet

pub fn unsubscribe<F, Srv>(self, unsubscribe: F) -> Self where
    F: IntoNewService<Srv>,
    Srv: NewService<Config = St, Request = Unsubscribe<St>, Response = (), InitError = C::Error, Error = C::Error> + 'static,
    Srv::Service: 'static, 

Service to execute for unsubscribe packet

pub fn disconnect<UF, U>(self, srv: UF) -> Self where
    UF: IntoService<U>,
    U: Service<Request = State<St>, Response = (), Error = C::Error> + 'static, 

Service to execute on disconnect

pub fn finish<F, T>(
    self,
    service: F
) -> impl Service<Request = Io, Response = (), Error = MqttError<C::Error>> where
    F: IntoNewService<T>,
    T: NewService<Config = St, Request = Publish<St>, Response = (), Error = C::Error, InitError = C::Error> + 'static,