Struct LocalConnection 

pub struct LocalConnection { /* private fields */ }

Connection strategy implementation communicating with a local subprocess harness.

LocalConnection handles launching and lifecycle tracking of the localharness binary, reading standard error output, upgrading communication to standard WebSockets, and managing subagent and tool invocation state.

Trait Implementations

impl Connection for LocalConnection

fn conversation_id(&self) -> &str

Returns the conversation ID for the connection.

fn is_idle(&self) -> bool

Returns whether the connection is currently idle.

fn receive_steps(&self) -> BoxStream<'static, Result<Step, Error>>

Subscribes to the stream of step updates from the connection.

async fn send(&self, content: &str) -> Result<(), Error>

Sends a standard user text prompt to the connection.

async fn send_trigger_notification(&self, content: &str) -> Result<(), Error>

Sends a trigger notification message to the connection.

async fn send_halt_request(&self) -> Result<(), Error>

Sends a halt/cancellation request to the connection.

async fn send_tool_confirmation( &self, trajectory_id: &str, step_index: u32, accepted: bool, ) -> Result<(), Error>

Sends approval/rejection for a tool execution confirmation request.

async fn send_tool_response( &self, id: &str, result: ToolResult, ) -> Result<(), Error>

Sends the result of a tool execution back to the connection.

async fn send_question_response( &self, trajectory_id: &str, step_index: u32, answers: QuestionHookResult, ) -> Result<(), Error>

Sends the answers to user questions back to the connection.

async fn disconnect(&self) -> Result<(), Error>

Gracefully closes the connection.

impl Debug for LocalConnection

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.