Unit 10 · React safely to live events

Restore subscriptions safely after reconnecting

You reconcile catalog changes and restore known subscription intent exactly once after reconnecting. Partial failure keeps the prior known-good ownership state.

9 focused minutesNot started

Unit example (nearest native match)

See the idea in context

let route = AxEventRoute {
    id: "resource-wake".into(),
    action: "wake".into(),
    r#match: json!({"types":["mcp.resource.updated"]}),
    target_id: Some("inventory-agent".into()),
    require_authenticated: true,
    ordering: "strict".into(), debounce_ms: 0, instance_key: None,
};
let mut runtime = AxEventRuntime::new(vec![route], json!({}))?;
runtime.register_target(target);
runtime.start()?;
let runtime = Arc::new(Mutex::new(runtime));
let mut source = AxMCPEventSource::with_policy(
    client.clone(), runtime.clone(), "inventory",
    "tenant:demo", "authenticated",
    AxMCPResourceSubscriptionPolicy::All,
);
source.start()?;
source.poll(); // Drain protocol callbacks on the host thread.

Run itIn your own project

cargo add axllm

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

let llm = ai("openai", json!({"apiKey": std::env::var("OPENAI_API_KEY")?}))?;
let classify = ax("review:string -> sentiment:class \"positive, negative, neutral\"")?;

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