Unit 10 · React safely to live events

Resume only the task that owns the event

You let input-required and terminal events resume only their identity-scoped owning continuation. Recorded envelopes make that boundary testable without a live server.

10 focused minutesNot started

Worked example

See the idea in context

let mut target = AxEventTarget::new("reindex-flow", invoke_flow);
target.wait_for = vec![json!({
    "kind":"mcp.task", "value":"taskKey",
    "metadata":{"taskId":task_id},
})];
target.map_input = Some(Arc::new(|event, continuation| Ok(json!({
    "taskId": continuation
        .map(|value| value.metadata["taskId"].clone())
        .unwrap_or_else(|| event.data["taskId"].clone()),
}))));
let routes = vec![
    route("task-start", "wake", "app.task.started", "reindex-flow"),
    route("task-resume", "resume", "mcp.task.status", "reindex-flow"),
];
let mut runtime = AxEventRuntime::new(routes, json!({}))?;
runtime.register_target(target);
runtime.start()?;

Run itIn your own project

cargo add axllm

use axllm::{ai, ax, AxResult};
use serde_json::json;

fn main() -> AxResult<()> {
    let mut llm = ai("openai", json!({"apiKey": std::env::var("OPENAI_API_KEY")?}))?;
    let mut classify = ax("review:string -> sentiment:class \"positive, negative, neutral\"")?;
    let result = classify.forward(&mut llm, json!({
        "review": "Useful and boring in the best way."
    }))?;

    println!("sentiment: {}", result["sentiment"].as_str().unwrap_or_default());
    Ok(())
}

Set OPENAI_APIKEY in your environment before running provider-backed code.

In the ax repo

From a clone of the ax repo:

npm run example -- rust src/examples/rust/mcp/resource_wake_agent.rs

Active practice

Show that you can use it

Answer 2 in a row to learn this · attempt 1

Keep exploring

See the idea in context

Show that you can use it

Source-backed follow-up