Struct Server

pub struct Server<Context: Context> { /* private fields */ }

Implementations

impl<Context: Context> Server<Context>

pub fn for_http(self) -> HttpServer<Context>

pub fn middleware<T: Middleware<Context>>( self, middleware: T, ) -> HttpServer<Context>

impl<Context: Context> Server<Context>

pub fn run_socket<'a, T: AsyncRead + AsyncWrite + Send>( &'a self, listener: impl Stream<Item = Result<T>> + 'a, error_handler: impl Fn(Error) + Sync + 'a, ) -> (ShutdownHandle, impl Future<Output = ()> + 'a)

pub fn run_unix<'a>( &'a self, path: impl AsRef<Path> + 'a, error_handler: impl Fn(Error) + Sync + 'a, ) -> Result<(ShutdownHandle, impl Future<Output = ()> + 'a)>

pub async fn run_tcp<'a>( &'a self, addr: impl ToSocketAddrs + 'a, error_handler: impl Fn(Error) + Sync + 'a, ) -> Result<(ShutdownHandle, impl Future<Output = ()> + 'a)>

impl<Context: Context> Server<Context>

pub fn new<MakeCtx: Fn() -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<Context, RpcError>> + Send + 'static>( make_ctx: MakeCtx, root_handler: ParentHandler<Context>, ) -> Self

pub fn handle_command( &self, method: &str, params: Value, ) -> impl Future<Output = Result<Value, RpcError>> + Send + 'static

pub fn handle( &self, request: Result<Value, RpcError>, ) -> BoxFuture<'static, Result<Value, Error>>

pub fn stream<'a>( &'a self, requests: impl Stream<Item = Result<Value, RpcError>> + Send + 'a, ) -> impl Stream<Item = Result<Value, Error>> + 'a

Trait Implementations

impl<Context: Context> Clone for Server<Context>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.