Struct MqttServer

pub struct MqttServer<V3, V5, Err, InitErr> { /* private fields */ }

Mqtt Server

Implementations

impl<Err, InitErr> MqttServer<DefaultProtocolServer<Err, InitErr>, DefaultProtocolServer<Err, InitErr>, Err, InitErr>

pub fn new() -> Self

Create mqtt server

impl<V3, V5, Err, InitErr> MqttServer<V3, V5, Err, InitErr>

pub fn protocol_version_timeout(self, timeout: Seconds) -> Self

Set client timeout reading protocol version.

Defines a timeout for reading protocol version. If a client does not transmit version of the protocol within this time, the connection is terminated with Mqtt::Handshake(HandshakeError::Timeout) error.

By default, timeuot is 5 seconds.

impl<V3, V5, Err, InitErr> MqttServer<V3, V5, Err, InitErr>

where Err: Debug, V3: ServiceFactory<IoBoxed, Response = (), Error = MqttError<Err>, InitError = InitErr>, V5: ServiceFactory<IoBoxed, Response = (), Error = MqttError<Err>, InitError = InitErr>,

pub fn v3<St, H, P, M, Codec>( self, service: MqttServer<St, H, P, M, Codec>, ) -> MqttServer<impl ServiceFactory<IoBoxed, Response = (), Error = MqttError<Err>, InitError = InitErr>, V5, Err, InitErr>

where St: 'static, H: ServiceFactory<IoBoxed, Response = (IoBoxed, Codec, St, Seconds), Error = MqttError<Err>, InitError = InitErr> + 'static, P: ServiceFactory<DispatchItem<Codec>, St, Response = Option<<Codec as Encoder>::Item>, Error = MqttError<Err>, InitError = MqttError<Err>> + 'static, M: Middleware<P::Service>, M::Service: Service<DispatchItem<Codec>, Response = Option<<Codec as Encoder>::Item>, Error = MqttError<Err>> + 'static, Codec: Encoder + Decoder + Clone + 'static,

Service to handle v3 protocol

pub fn v5<St, H, P, M, Codec>( self, service: MqttServer<St, H, P, M, Codec>, ) -> MqttServer<V3, impl ServiceFactory<IoBoxed, Response = (), Error = MqttError<Err>, InitError = InitErr>, Err, InitErr>

where St: 'static, H: ServiceFactory<IoBoxed, Response = (IoBoxed, Codec, St, Seconds), Error = MqttError<Err>, InitError = InitErr> + 'static, P: ServiceFactory<DispatchItem<Codec>, St, Response = Option<<Codec as Encoder>::Item>, Error = MqttError<Err>, InitError = MqttError<Err>> + 'static, M: Middleware<P::Service>, M::Service: Service<DispatchItem<Codec>, Response = Option<<Codec as Encoder>::Item>, Error = MqttError<Err>> + 'static, Codec: Encoder + Decoder + Clone + 'static,

Service to handle v5 protocol

Trait Implementations

impl<Err, InitErr> Default for MqttServer<DefaultProtocolServer<Err, InitErr>, DefaultProtocolServer<Err, InitErr>, Err, InitErr>

fn default() -> Self

Returns the “default value” for a type.

impl<F, V3, V5, Err, InitErr> ServiceFactory<Io<F>> for MqttServer<V3, V5, Err, InitErr>

where F: Filter, V3: ServiceFactory<IoBoxed, Response = (), Error = MqttError<Err>, InitError = InitErr> + 'static, V5: ServiceFactory<IoBoxed, Response = (), Error = MqttError<Err>, InitError = InitErr> + 'static, Err: 'static, InitErr: 'static,

type Response = ()

Responses given by the created services.

type Error = MqttError<Err>

Errors produced by the created services.

type Service = MqttServerImpl<<V3 as ServiceFactory<IoBoxed>>::Service, <V5 as ServiceFactory<IoBoxed>>::Service, Err>

The kind of Service created by this factory.

type InitError = InitErr

Errors potentially raised while building a service.

async fn create(&self, _: ()) -> Result<Self::Service, Self::InitError>

Create and return a new service value asynchronously.

async fn pipeline( &self, cfg: Cfg, ) -> Result<Pipeline<Self::Service>, Self::InitError>

where Self: Sized,

Create and return a new service value asynchronously and wrap into a container

fn map<F, Res>( self, f: F, ) -> ServiceChainFactory<MapFactory<Self, F, Req, Res, Cfg>, Req, Cfg>

where Self: Sized, F: Fn(Self::Response) -> Res + Clone,

Map this service’s output to a different type, returning a new service of the resulting type.

fn map_err<F, E>( self, f: F, ) -> ServiceChainFactory<MapErrFactory<Self, Req, Cfg, F, E>, Req, Cfg>

where Self: Sized, F: Fn(Self::Error) -> E + Clone,

Map this service’s error to a different error, returning a new service.

fn map_init_err<F, E>( self, f: F, ) -> ServiceChainFactory<MapInitErr<Self, Req, Cfg, F, E>, Req, Cfg>

where Self: Sized, F: Fn(Self::InitError) -> E + Clone,

Map this factory’s init error to a different error, returning a new service.

impl<V3, V5, Err, InitErr> ServiceFactory<IoBoxed> for MqttServer<V3, V5, Err, InitErr>

where V3: ServiceFactory<IoBoxed, Response = (), Error = MqttError<Err>, InitError = InitErr> + 'static, V5: ServiceFactory<IoBoxed, Response = (), Error = MqttError<Err>, InitError = InitErr> + 'static, Err: 'static, InitErr: 'static,

type Response = ()

Responses given by the created services.

type Error = MqttError<Err>

Errors produced by the created services.

type Service = MqttServerImpl<<V3 as ServiceFactory<IoBoxed>>::Service, <V5 as ServiceFactory<IoBoxed>>::Service, Err>

The kind of Service created by this factory.

type InitError = InitErr

Errors potentially raised while building a service.

async fn create(&self, _: ()) -> Result<Self::Service, Self::InitError>

Create and return a new service value asynchronously.

async fn pipeline( &self, cfg: Cfg, ) -> Result<Pipeline<Self::Service>, Self::InitError>

where Self: Sized,

Create and return a new service value asynchronously and wrap into a container

fn map<F, Res>( self, f: F, ) -> ServiceChainFactory<MapFactory<Self, F, Req, Res, Cfg>, Req, Cfg>

where Self: Sized, F: Fn(Self::Response) -> Res + Clone,

Map this service’s output to a different type, returning a new service of the resulting type.

fn map_err<F, E>( self, f: F, ) -> ServiceChainFactory<MapErrFactory<Self, Req, Cfg, F, E>, Req, Cfg>

where Self: Sized, F: Fn(Self::Error) -> E + Clone,

Map this service’s error to a different error, returning a new service.

fn map_init_err<F, E>( self, f: F, ) -> ServiceChainFactory<MapInitErr<Self, Req, Cfg, F, E>, Req, Cfg>

where Self: Sized, F: Fn(Self::InitError) -> E + Clone,

Map this factory’s init error to a different error, returning a new service.