Struct AppServerRpc 

pub struct AppServerRpc { /* private fields */ }

Initialized app-server connection.

Implementations

impl AppServerRpc

pub async fn connect<R, W>( reader: R, writer: W, config: RpcConfig, ) -> Result<Arc<Self>, BridgeError>

where R: AsyncRead + Send + Unpin + 'static, W: AsyncWrite + Send + Unpin + 'static,

Connects to app-server and completes initialize/initialized exactly once.

pub fn subscribe(&self) -> Receiver<RpcNotification>

Subscribes before starting a turn so no notification is missed.

pub fn is_closed(&self) -> bool

Returns whether the read or write side has failed permanently.

pub async fn request( &self, method: &str, params: Value, ) -> Result<Value, BridgeError>

Sends a request using the default timeout.

pub async fn request_until( &self, method: &str, params: Value, deadline: Instant, cancellation: CancellationToken, ) -> Result<Value, BridgeError>

Sends a request bounded by an absolute deadline and cancellation token.

pub async fn request_side_effecting_until( &self, method: &str, params: Value, deadline: Instant, cancellation: CancellationToken, ) -> Result<Value, BridgeError>

Sends a side-effecting request and marks post-flush ambiguity explicitly.

pub async fn notify( &self, method: &str, params: Option<Value>, ) -> Result<(), BridgeError>

Sends a JSONL notification.

Trait Implementations

impl Debug for AppServerRpc

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.