Struct AgentSideConnection 

pub struct AgentSideConnection { /* private fields */ }

An agent-side connection to a client.

This struct provides the agent’s view of an ACP connection, allowing agents to communicate with clients. It implements the Client trait to provide methods for requesting permissions, accessing the file system, and sending session updates.

See: https://agentclientprotocol.com/protocol/overview#agent

Implementations

impl AgentSideConnection

pub fn new( agent: impl MessageHandler<AgentSide> + 'static, outgoing_bytes: impl Unpin + AsyncWrite, incoming_bytes: impl Unpin + AsyncRead, spawn: impl Fn(LocalBoxFuture<'static, ()>) + 'static, ) -> (Self, impl Future<Output = Result<()>>)

Creates a new agent-side connection to a client.

This establishes the communication channel from the agent’s perspective following the ACP specification.

Arguments

• agent - A handler that implements the Agent trait to process incoming client requests
• outgoing_bytes - The stream for sending data to the client (typically stdout)
• incoming_bytes - The stream for receiving data from the client (typically stdin)
• spawn - A function to spawn async tasks (e.g., tokio::spawn)

Returns

Returns a tuple containing:

• The connection instance for making requests to the client
• An I/O future that must be spawned to handle the underlying communication

See: https://agentclientprotocol.com/protocol/overview#communication-model

pub fn subscribe(&self) -> StreamReceiver

Subscribe to receive stream updates from the client.

This allows the agent to receive real-time notifications about client activities and cancellation requests.

Returns

A StreamReceiver that can be used to receive stream messages.

Trait Implementations

impl Client for AgentSideConnection

async fn request_permission( &self, arguments: RequestPermissionRequest, ) -> Result<RequestPermissionResponse, Error>

Requests permission from the user for a tool call operation.

async fn write_text_file( &self, arguments: WriteTextFileRequest, ) -> Result<(), Error>

Writes content to a text file in the client’s file system.

async fn read_text_file( &self, arguments: ReadTextFileRequest, ) -> Result<ReadTextFileResponse, Error>

Reads content from a text file in the client’s file system.

async fn session_notification( &self, notification: SessionNotification, ) -> Result<(), Error>

Handles session update notifications from the agent.