Struct jsonrpc_ipc_server::ServerBuilder

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

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.