Struct AcpProcess 

pub struct AcpProcess { /* private fields */ }

A managed ACP agent child process.

Implementations

impl AcpProcess

pub async fn spawn( command: &str, args: &[&str], cwd: &str, notification_tx: Sender<Value>, display_name: &str, our_session_id: &str, ) -> Result<AcpProcess, String>

Spawn the agent process and start the background reader.

our_session_id is used to rewrite the agent’s session ID in notifications so the frontend SSE stream matches on the correct session.

pub fn is_alive(&self) -> bool

Whether the process is still alive.

pub async fn send_request( &self, method: &str, params: Value, timeout_ms: Option<u64>, ) -> Result<Value, String>

Send a JSON-RPC request and wait for the response.

pub async fn initialize(&self) -> Result<Value, String>

Initialize the ACP protocol.

pub async fn initialize_with_timeout( &self, timeout_ms: Option<u64>, ) -> Result<Value, String>

Initialize the ACP protocol with an optional timeout override.

pub async fn new_session( &self, cwd: &str, mcp_servers: &[Value], ) -> Result<String, String>

Create a new ACP session. Returns the agent’s session ID.

pub async fn load_session( &self, session_id: &str, cwd: &str, mcp_servers: &[Value], ) -> Result<String, String>

Load a persisted ACP session. Returns the agent’s resumed session ID.

pub async fn prompt( &self, session_id: &str, text: &str, ) -> Result<Value, String>

Send a prompt to an existing session. 5-minute timeout.

pub async fn cancel(&self, session_id: &str)

Send session/cancel notification (no response expected).

pub fn notification_sender(&self) -> &Sender<Value>

Get the notification broadcast sender (for subscribing to SSE).

pub async fn kill(&self)

Kill the agent process.