Struct AcpClientV2 

pub struct AcpClientV2 { /* private fields */ }

ACP Client V2 with full protocol compliance

This client implements the complete ACP session lifecycle:

1. initialize() - Negotiate protocol version and capabilities
2. authenticate() - Optional authentication (if required by agent)
3. session_new() - Create a new conversation session
4. session_prompt() - Send prompts and receive responses
5. session_cancel() - Cancel ongoing operations

Streaming updates are delivered via SSE and can be subscribed to using subscribe_updates().

Implementations

impl AcpClientV2

pub fn new(base_url: impl Into<String>) -> AcpResult<Self>

Create a new client with default settings

pub async fn is_initialized(&self) -> bool

Check if client has been initialized

pub async fn protocol_version(&self) -> Option<String>

Get negotiated protocol version

pub async fn agent_capabilities(&self) -> Option<AgentCapabilities>

Get agent capabilities (after initialization)

pub async fn initialize(&self) -> AcpResult<InitializeResult>

Initialize the connection with the agent

This must be called before any other method. It negotiates:

• Protocol version
• Client and agent capabilities
• Authentication requirements

pub async fn authenticate( &self, params: AuthenticateParams, ) -> AcpResult<AuthenticateResult>

Authenticate with the agent (if required)

pub async fn session_new( &self, params: SessionNewParams, ) -> AcpResult<SessionNewResult>

Create a new session

pub async fn session_load( &self, session_id: &str, ) -> AcpResult<SessionLoadResult>

Load an existing session

pub async fn session_prompt( &self, params: SessionPromptParams, ) -> AcpResult<SessionPromptResult>

Send a prompt to the session

Returns the turn result. For streaming responses, use subscribe_updates() before calling this method.

pub async fn session_prompt_with_timeout( &self, params: SessionPromptParams, timeout: Option<Duration>, ) -> AcpResult<SessionPromptResult>

Send a prompt with a custom timeout

pub async fn session_cancel( &self, session_id: &str, turn_id: Option<&str>, ) -> AcpResult<()>

Cancel an ongoing operation

pub async fn get_session(&self, session_id: &str) -> Option<AcpSession>

Get a session by ID

pub async fn list_sessions(&self) -> Vec<AcpSession>

List all active sessions

pub async fn subscribe_updates( &self, session_id: &str, ) -> AcpResult<Receiver<SessionUpdateNotification>>

Subscribe to session updates via Server-Sent Events

Returns a receiver channel that will receive update notifications. The connection will remain open until the receiver is dropped.