Quickstart

[dependencies]
anyagent = "0.0.1"
futures = "0.3"
tokio = { version = "1", features = ["rt-multi-thread", "macros"] }

use anyagent::{EventKind, Runtime, SessionOptions};
use futures::StreamExt;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let runtime = Runtime::new();

    // 1. Find what's on this machine, then insist on one of them.
    let report = runtime.discover().await;
    let agent = report.require("claude")?;

    // 2. Open a session: a command handle and an event stream.
    let (session, mut events) = runtime.open(agent, SessionOptions::in_dir(".")).await?;

    // 3. Prompt, then drain events until the turn ends.
    session.prompt("explain this repo").await?;
    while let Some(event) = events.next().await {
        match event?.kind {
            EventKind::TextDelta { text, .. } => print!("{text}"),
            EventKind::TurnEnded { .. } => break,
            _ => {}
        }
    }

    session.close().await?;
    Ok(())
}