Struct Server

pub struct Server<Io, St, Cn: ServiceFactory> { /* private fields */ }

Server dispatcher factory

Implementations

impl<Io, St, Cn> Server<Io, St, Cn>

where St: 'static, Io: AsyncRead + AsyncWrite + 'static, Cn: ServiceFactory<Config = (), Request = Either<Connect<Io>, Sasl<Io>>, Response = ConnectAck<Io, St>> + 'static,

pub fn new<F>(connect: F) -> Self

where F: IntoServiceFactory<Cn>,

Create server factory and provide connect service

pub fn config(self, config: Configuration) -> Self

Provide connection configuration

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 handshake_timeout(self, timeout: u64) -> Self

Set handshake timeout in millis.

By default handshake timeuot is disabled.

pub fn control<F, S>(self, f: F) -> Self

where F: IntoServiceFactory<S>, S: ServiceFactory<Config = (), Request = ControlFrame<St>, Response = (), InitError = ()> + 'static, S::Error: Into<LinkError>,

Service to call with control frames

pub fn disconnect<F, Out>(self, disconnect: F) -> Self

where F: Fn(&mut St, Option<&ServerError<Cn::Error>>) -> Out + 'static, Out: Future + 'static,

Callback to execute on disconnect

Second parameter indicates error occured during disconnect.

pub fn finish<F, Pb>( self, service: F, ) -> impl ServiceFactory<Config = (), Request = Io, Response = (), Error = ServerError<Cn::Error>>

where F: IntoServiceFactory<Pb>, Pb: ServiceFactory<Config = State<St>, Request = Link<St>, Response = ()> + 'static, Pb::Error: Display + Into<Error>, Pb::InitError: Display + Into<Error>,

Set service to execute for incoming links and create service factory