Struct ServerBuilder

pub struct ServerBuilder<M: Metadata = (), S: Middleware<M> = Noop> { /* private fields */ }

IPC server builder

Implementations

impl<M: Metadata + Default, S: Middleware<M>> ServerBuilder<M, S>

where S::Future: Unpin, S::CallFuture: Unpin,

pub fn new<T>(io_handler: T) -> ServerBuilder<M, S>

where T: Into<MetaIoHandler<M, S>>,

Creates new IPC server build given the IoHandler.

impl<M: Metadata, S: Middleware<M>> ServerBuilder<M, S>

where S::Future: Unpin, S::CallFuture: Unpin,

pub fn with_meta_extractor<T, E>( io_handler: T, extractor: E, ) -> ServerBuilder<M, S>

where T: Into<MetaIoHandler<M, S>>, E: MetaExtractor<M>,

Creates new IPC server build given the IoHandler and metadata extractor.

pub fn event_loop_executor(self, executor: TaskExecutor) -> Self

Sets shared different event loop executor.

pub fn session_meta_extractor<X>(self, meta_extractor: X) -> Self

where X: MetaExtractor<M>,

Sets session metadata extractor.

pub fn session_stats<T: SessionStats>(self, stats: T) -> Self

Session stats

pub fn request_separators( self, incoming: Separator, outgoing: Separator, ) -> Self

Sets the incoming and outgoing requests separator

pub fn set_security_attributes(self, attr: SecurityAttributes) -> Self

Sets the security attributes for the underlying IPC socket/pipe

pub fn set_client_buffer_size(self, buffer_size: usize) -> Self

Sets how many concurrent requests per client can be processed at any one time. Set to 5 by default.

pub fn start(self, path: &str) -> Result<Server>

Creates a new server from the given endpoint.