pub struct ServiceBuilder<Io, St, C: Service> { /* private fields */ }Implementations§
Source§impl<Io, St, C> ServiceBuilder<Io, St, C>where
St: Clone + 'static,
Io: AsyncRead + AsyncWrite + 'static,
C: Service<Request = ConnectAck<Io>, Response = ConnectAckResult<Io, St>> + 'static,
C::Error: 'static,
impl<Io, St, C> ServiceBuilder<Io, St, C>where
St: Clone + 'static,
Io: AsyncRead + AsyncWrite + 'static,
C: Service<Request = ConnectAck<Io>, Response = ConnectAckResult<Io, St>> + 'static,
C::Error: 'static,
Sourcepub fn disconnect<UF, U>(self, srv: UF) -> Self
pub fn disconnect<UF, U>(self, srv: UF) -> Self
Service to execute on disconnect
pub fn finish<F, T>(
self,
service: F,
) -> impl Service<Request = Io, Response = (), Error = MqttError<C::Error>>where
F: IntoServiceFactory<T>,
T: ServiceFactory<Config = St, Request = Publish<St>, Response = (), Error = C::Error, InitError = C::Error> + 'static,
Auto Trait Implementations§
impl<Io, St, C> !Freeze for ServiceBuilder<Io, St, C>
impl<Io, St, C> !RefUnwindSafe for ServiceBuilder<Io, St, C>
impl<Io, St, C> !Send for ServiceBuilder<Io, St, C>
impl<Io, St, C> !Sync for ServiceBuilder<Io, St, C>
impl<Io, St, C> Unpin for ServiceBuilder<Io, St, C>
impl<Io, St, C> !UnwindSafe for ServiceBuilder<Io, St, C>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more