Struct AcpAgent 

pub struct AcpAgent { /* private fields */ }

A running ACP agent subprocess.

Implementations

impl AcpAgent

pub fn spawn<S, F>( command: &[S], cwd: &Path, capabilities: ClientCapabilities, sink: F, ) -> Result<Self>

where S: AsRef<OsStr>, F: Fn(AgentEvent) + Send + 'static,

Spawn command and connect to it.

command is an argv array — never a shell string, and never assembled into one (ARCHITECTURE.md §11). sink receives every event; the app wraps it in AppMessage::Agent so agent traffic wakes the main loop exactly as filesystem traffic does.

pub fn connect<F>( stdin: Box<dyn Write + Send>, stdout: Box<dyn BufRead + Send>, capabilities: ClientCapabilities, sink: F, ) -> Self

where F: Fn(AgentEvent) + Send + 'static,

Connect over arbitrary streams.

Exists so the transport can be driven by in-memory pipes in tests: everything except spawn is then exercised without an agent installed.

Trait Implementations

impl AgentService for AcpAgent

fn poll(&mut self) -> Vec<AgentEvent>

Always empty.

Events reach the app through the sink, not by polling: the main loop blocks on its message channel, so a client that only answered when asked would never be asked. The scripted agent uses poll; both end at Model::on_agent_event.

fn integration(&self) -> AgentIntegration

fn capabilities(&self) -> ClientCapabilities

fn send(&mut self, request: AgentRequest)

Queue work for the agent. Never blocks the caller.

impl Drop for AcpAgent

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.