Struct MqttServer

pub struct MqttServer<Io, St, C: ServiceFactory, U> { /* private fields */ }

Mqtt Server

Implementations

impl<Io, St, C> MqttServer<Io, St, C, ()>

where St: 'static, C: ServiceFactory<Config = (), Request = Connect<Io>, Response = ConnectAck<Io, St>> + 'static,

pub fn new<F>(connect: F) -> MqttServer<Io, St, C, impl Fn(St, bool)>

where F: IntoServiceFactory<C>,

Create server factory and provide connect service

impl<Io, St, C, U> MqttServer<Io, St, C, U>

where St: Clone + 'static, U: Fn(St, bool) + 'static, C: ServiceFactory<Config = (), Request = Connect<Io>, Response = ConnectAck<Io, St>> + 'static,

pub fn handshake_timeout(self, timeout: u64) -> Self

Set handshake timeout in millis.

Handshake includes connect packet and response connect-ack. By default handshake timeuot is disabled.

pub fn max_size(self, size: usize) -> Self

Set max inbound frame size.

If max size is set to 0, size is unlimited. By default max size is set to 0

pub fn inflight(self, val: usize) -> Self

Number of in-flight concurrent messages.

in-flight is set to 15 messages

pub fn subscribe<F, Srv>(self, subscribe: F) -> Self

where F: IntoServiceFactory<Srv>, Srv: ServiceFactory<Config = St, Request = Subscribe<St>, Response = SubscribeResult> + 'static, C::Error: From<Srv::Error> + From<Srv::InitError>,

Service to execute for subscribe packet

pub fn unsubscribe<F, Srv>(self, unsubscribe: F) -> Self

where F: IntoServiceFactory<Srv>, Srv: ServiceFactory<Config = St, Request = Unsubscribe<St>, Response = ()> + 'static, C::Error: From<Srv::Error> + From<Srv::InitError>,

Service to execute for unsubscribe packet

pub fn disconnect<F, Out>( self, disconnect: F, ) -> MqttServer<Io, St, C, impl Fn(St, bool)>

where F: Fn(St, bool) -> Out, Out: Future + 'static,

Callback to execute on disconnect

Second parameter indicates error occured during disconnect.

pub fn finish<F, P>( self, publish: F, ) -> impl ServiceFactory<Config = (), Request = Io, Response = (), Error = MqttError<C::Error>>

where Io: AsyncRead + AsyncWrite + 'static, F: IntoServiceFactory<P>, P: ServiceFactory<Config = St, Request = Publish<St>, Response = ()> + 'static, C::Error: From<P::Error> + From<P::InitError>,

Set service to execute for publish packet and create service factory