Struct Client 

pub struct Client { /* private fields */ }

A multiplexed SecretSpec JSON-RPC session.

Implementations

impl Client

pub async fn connect<R, W, A, B>( reader: R, writer: W, initialize: InitializeParams<A>, startup_deadline_unix_ms: u64, ) -> Result<(Self, InitializeResult<B>)>

where R: AsyncRead + Unpin + Send + 'static, W: AsyncWrite + Unpin + Send + 'static, A: Serialize, B: DeserializeOwned,

Initialize a session on an already-authenticated private transport.

pub async fn connect_with_callbacks<R, W, A, B>( reader: R, writer: W, initialize: InitializeParams<A>, startup_deadline_unix_ms: u64, callbacks: Option<Arc<dyn CallbackHandler>>, ) -> Result<(Self, InitializeResult<B>)>

where R: AsyncRead + Unpin + Send + 'static, W: AsyncWrite + Unpin + Send + 'static, A: Serialize, B: DeserializeOwned,

As Self::connect, installing a handler for the callbacks this client advertised in client_methods (0.21+).

Passing None while advertising a callback would leave the server waiting out its deadline on a request nothing answers, so the two are checked against each other here rather than at the first callback.

pub async fn start<T: Serialize>( &self, method: &str, params: &T, deadline_unix_ms: u64, ) -> Result<Call>

pub async fn call<P: Serialize, R: DeserializeOwned>( &self, method: &str, params: &P, deadline_unix_ms: u64, ) -> Result<R>

pub async fn limits(&self) -> Limits

pub async fn capabilities(&self) -> HashSet<String>

pub fn is_closed(&self) -> bool

pub async fn close(&self, deadline_unix_ms: u64) -> Result<()>

Close the protocol session. The process launcher separately enforces child termination and reaping after this wire shutdown completes.

pub async fn abandon(&self)

Mark a transport dead from a process watcher without exposing pending request data in an error.

Trait Implementations

impl Clone for Client

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.