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 protocol docs: 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 protocol docs: 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<WriteTextFileResponse, 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 create_terminal( &self, arguments: CreateTerminalRequest, ) -> Result<CreateTerminalResponse, Error>

Executes a command in a new terminal

async fn terminal_output( &self, arguments: TerminalOutputRequest, ) -> Result<TerminalOutputResponse, Error>

Gets the terminal output and exit status

async fn release_terminal( &self, arguments: ReleaseTerminalRequest, ) -> Result<ReleaseTerminalResponse, Error>

Releases a terminal

async fn wait_for_terminal_exit( &self, arguments: WaitForTerminalExitRequest, ) -> Result<WaitForTerminalExitResponse, Error>

Waits for the terminal command to exit and return its exit status

async fn kill_terminal_command( &self, arguments: KillTerminalCommandRequest, ) -> Result<KillTerminalCommandResponse, Error>

Kills the terminal command without releasing the terminal

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

Handles session update notifications from the agent.

async fn ext_method( &self, method: Arc<str>, params: Arc<RawValue>, ) -> Result<Arc<RawValue>, Error>

Handles extension method requests from the agent.

async fn ext_notification( &self, method: Arc<str>, params: Arc<RawValue>, ) -> Result<(), Error>

Handles extension notifications from the agent.