Struct RpcServer 

pub struct RpcServer<Context, T: Transport + ?Sized> { /* private fields */ }

RpcServer receives and process different requests from the RpcClient

Once a RpcServer is inited, you should attach a transport and handler for the port creation.

Implementations

impl<Context: Send + Sync + 'static, T: Transport + ?Sized + 'static> RpcServer<Context, T>

pub fn create(ctx: Context) -> Self

pub fn get_server_events_sender(&self) -> ServerEventsSender<T>

Get a ServerEventsSender to send allowed server events from outside

pub async fn attach_transport(&mut self, transport: Arc<T>) -> ServerResult<()>

Attaches the server half of the transport for Client<>Server communications

It differs from sending the ServerEvents::AtacchTransport because it can only be used to attach transport from the current thread where the RpcServer was initalized due to the mutably borrow

It receives the Transport inside an Arc because it must be sharable.

pub async fn run(&mut self)

Start processing ServerEvent events and listening on a channel for new TransportNotification that are sent by all the attached transports that are running in background tasks.

pub fn set_module_registrator_handler<H>(&mut self, handler: H)

where H: Fn(&mut RpcServerPort<Context>) + Send + Sync + 'static,

Set a handler for the port creation

When a port is created, a service should be registered for the port.

pub fn set_on_transport_closes_handler<H>(&mut self, handler: H)

where H: Fn(Arc<T>, u32) + Send + Sync + 'static,

Set a handler to be executed when a transport was closed

When a transport closes its connection, the closure will be executed.

This could be useful when there are resources that may be tied to or depends on a transport’s connection

pub fn set_on_transport_connected_handler<H>(&mut self, handler: H)

where H: Fn(Arc<T>, u32) + Send + Sync + 'static,

Set a handler is executed when a transport is put to run.

It works for executing a function which receives the Transport ID assigned by the server to a new running transport