Struct AgentConnection

pub struct AgentConnection(/* private fields */);

A connection to a separate agent process over the ACP protocol.

Implementations

impl AgentConnection

pub fn connect_to_agent<H: 'static + Client>( handler: H, outgoing_bytes: impl Unpin + AsyncWrite, incoming_bytes: impl Unpin + AsyncRead, spawn: impl Fn(LocalBoxFuture<'static, ()>) + 'static, ) -> (Self, impl Future<Output = Result<(), Error>>)

Connect to an agent process, handling any incoming requests using the given handler.

pub fn request<R: AgentRequest + 'static>( &self, params: R, ) -> impl Future<Output = Result<R::Response, Error>>

Send a request to the agent and wait for a response.

pub fn request_any( &self, params: AnyAgentRequest, ) -> impl use<> + Future<Output = Result<AnyAgentResult, Error>>

Send an untyped request to the agent and wait for a response.

pub async fn initialize( &self, context_servers: HashMap<String, ContextServer>, ) -> Result<InitializeResponse, Error>

Sends an initialization request to the Agent. This will error if the server version is incompatible with the client version.