Struct InProcessBackend 

pub struct InProcessBackend { /* private fields */ }

A SessionBackend over a live runtime in this process.

Runtime-agnostic (GA-40): commands awaited from a non-tokio executor (GPUI) run on the tokio runtime the backend was created on.

Implementations

impl InProcessBackend

pub fn new(runtime: Arc<AgentSessionRuntime>) -> Self

Wraps runtime.

pub fn with_server_info( runtime: Arc<AgentSessionRuntime>, server: ServerInfo, ) -> Self

Wraps runtime, reporting server from _oino/hello. Commands awaited outside a tokio runtime run on the runtime current here (or the session’s own runtime).

pub fn runtime(&self) -> &Arc<AgentSessionRuntime>

The runtime.

pub fn state(&self) -> RpcSessionState

Returns the state.

Trait Implementations

impl Debug for InProcessBackend

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

Formats the value using the given formatter.

impl SessionBackend for InProcessBackend

fn events(&self) -> BoxStream<'static, ClientEvent>

Events of the current session; streams follow session replacements made through this backend and end after SessionBackend::shutdown.

fn shutdown_requested(&self) -> BoxFuture<'static, ()>

Resolves once an extension called ctx.shutdown() and the session is idle.

fn send( &self, command: RpcCommand, ) -> BoxFuture<'_, Result<RpcResponseData, ClientError>>

Any agent session or _oino/* command; returns the response data.

fn send_with_id( &self, request_id: Option<String>, command: RpcCommand, ) -> BoxFuture<'_, Result<RpcResponseData, ClientError>>

SessionBackend::send with the RPC request id; bash streams bash_execution_update{id} with it (the command id goes to executeBash).

fn ui_respond(&self, response: UiResponse)

Answers a dialog (extension_ui_response); idempotent, first answer wins.

fn session_id(&self) -> String

Current session id.

fn shutdown(&self) -> BoxFuture<'_, ()>

Orderly shutdown (session_shutdown{reason:"quit"}); later commands fail with ClientError::Closed.