Struct ntex_mqtt::v3::Selector

pub struct Selector<Err, InitErr> { /* private fields */ }

Mqtt server selector

Selector allows to choose different mqtt server impls depends on connectt packet.

Implementations

impl<Err, InitErr> Selector<Err, InitErr>

pub fn new() -> Self

impl<Err, InitErr> Selector<Err, InitErr>where
    Err: 'static,
    InitErr: 'static,

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

Set handshake timeout.

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

pub fn max_size(self, size: u32) -> 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 variant<F, R, St, C, Cn, P>(
    self,
    check: F,
    server: MqttServer<St, C, Cn, P>
) -> Selfwhere
    F: Fn(&Handshake) -> R + 'static,
    R: Future<Output = Result<bool, Err>> + 'static,
    St: 'static,
    C: ServiceFactory<Handshake, Response = HandshakeAck<St>, Error = Err, InitError = InitErr> + 'static,
    Cn: ServiceFactory<ControlMessage<Err>, Session<St>, Response = ControlResult> + 'static,
    P: ServiceFactory<Publish, Session<St>, Response = ()> + 'static,
    C::Error: From<Cn::Error> + From<Cn::InitError> + From<P::Error> + From<P::InitError> + Debug,

Add server variant

Trait Implementations

impl<Err, InitErr> ServiceFactory<(IoBoxed, Deadline), ()> for Selector<Err, InitErr>where
    Err: 'static,
    InitErr: 'static,

type Response = ()

Responses given by the service

type Error = MqttError<Err>

Errors produced by the service

type InitError = InitErr

Errors produced while building a service.

type Service = SelectorService<Err>

The Service value created by this factory

type Future = Pin<Box<dyn Future<Output = Result<<Selector<Err, InitErr> as ServiceFactory<(IoBoxed, Deadline), ()>>::Service, <Selector<Err, InitErr> as ServiceFactory<(IoBoxed, Deadline), ()>>::InitError>> + 'static, Global>>

The future of the ServiceFactory instance.

fn new_service(&self, _: ()) -> Self::Future

Create and return a new service value asynchronously.

fn map<F, Res>(self, f: F) -> MapServiceFactory<Self, F, Req, Res, Cfg>where
    Self: Sized,
    F: FnMut(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) -> MapErrServiceFactory<Self, Req, Cfg, F, E>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) -> MapInitErr<Self, Req, Cfg, F, E>where
    Self: Sized,
    F: Fn(Self::InitError) -> E + Clone,

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

impl<F, Err, InitErr> ServiceFactory<Io<F>, ()> for Selector<Err, InitErr>where
    F: Filter,
    Err: 'static,
    InitErr: 'static,

type Response = ()

Responses given by the service

type Error = MqttError<Err>

Errors produced by the service

type InitError = InitErr

Errors produced while building a service.

type Service = SelectorService<Err>

The Service value created by this factory

type Future = Pin<Box<dyn Future<Output = Result<<Selector<Err, InitErr> as ServiceFactory<Io<F>, ()>>::Service, <Selector<Err, InitErr> as ServiceFactory<Io<F>, ()>>::InitError>> + 'static, Global>>

The future of the ServiceFactory instance.

fn new_service(&self, _: ()) -> Self::Future

Create and return a new service value asynchronously.

fn map<F, Res>(self, f: F) -> MapServiceFactory<Self, F, Req, Res, Cfg>where
    Self: Sized,
    F: FnMut(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) -> MapErrServiceFactory<Self, Req, Cfg, F, E>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) -> MapInitErr<Self, Req, Cfg, F, E>where
    Self: Sized,
    F: Fn(Self::InitError) -> E + Clone,

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

impl<Err, InitErr> ServiceFactory<IoBoxed, ()> for Selector<Err, InitErr>where
    Err: 'static,
    InitErr: 'static,

type Response = ()

Responses given by the service

type Error = MqttError<Err>

Errors produced by the service

type InitError = InitErr

Errors produced while building a service.

type Service = SelectorService<Err>

The Service value created by this factory

type Future = Pin<Box<dyn Future<Output = Result<<Selector<Err, InitErr> as ServiceFactory<IoBoxed, ()>>::Service, <Selector<Err, InitErr> as ServiceFactory<IoBoxed, ()>>::InitError>> + 'static, Global>>

The future of the ServiceFactory instance.

fn new_service(&self, _: ()) -> Self::Future

Create and return a new service value asynchronously.

fn map<F, Res>(self, f: F) -> MapServiceFactory<Self, F, Req, Res, Cfg>where
    Self: Sized,
    F: FnMut(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) -> MapErrServiceFactory<Self, Req, Cfg, F, E>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) -> MapInitErr<Self, Req, Cfg, F, E>where
    Self: Sized,
    F: Fn(Self::InitError) -> E + Clone,

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