Struct RpcSession 

pub struct RpcSession<T> { /* private fields */ }

Implementations

impl<T: RpcServer> RpcSession<T>

pub fn create(server: T) -> (Self, Receiver<Message>)

pub fn new(client: RpcClient, server: T) -> Self

pub fn client(&self) -> &RpcClient

Returns a reference to the JSON-RPC client.

pub fn server(&self) -> &T

Returns a reference to the JSON-RPC server.

pub fn into_sink(self) -> RpcSessionSink<T>

pub async fn process_incoming(&self, input: &str) -> Option<Message>

Processes incoming JSON-RPC message.

Handles incoming requests and notifications, returns a response if any.

See also [process_incoming_parsed].

pub async fn process_incoming_parsed(&self, message: Message) -> Option<Message>

Same as [process_incoming], but accepts a parsed Message instead of a string.

pub async fn handle_incoming(&self, input: &str)

Handles incoming JSON-RPC request.

Sends response to the client. Blocks until request handler finishes. Spawn a task if you want to run the request handler concurrently.

See also [handle_incoming_parsed].

pub async fn handle_incoming_parsed(&self, message: Message)

Same as [handle_incoming], but accepts a parsed Message instead of a string.

Trait Implementations

impl<T: Clone> Clone for RpcSession<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.