Struct RpcServer 

pub struct RpcServer<F>
where
    F: ServerFacts,
{ /* private fields */ }

An RpcServer that listen, accept, and server connections, according to ServerFacts interface.

Implementations

impl<F> RpcServer<F>

where F: ServerFacts,

pub fn new(facts: Arc<F>) -> Self

pub async fn listen<T: ServerTransport, D: Dispatch>( &mut self, addr: &str, dispatch: D, ) -> Result<String>

pub async fn close(&mut self)

Gracefully close the server

Steps:

• listeners coroutine is abort
• drop the close channel to notify connection read coroutines.
• the writer coroutines will exit after all the reference of RespNoti channel drop to 0
• wait for connection coroutines to exit with a timeout defined by ServerConfig.server_close_wait