//! Worker cancellation demo //! //! Example of cancelling from another thread during streaming use llm_worker::llm_client::providers::anthropic::AnthropicClient; use llm_worker::{Worker, WorkerResult}; use std::time::Duration; #[tokio::main] async fn main() -> Result<(), Box> { // Load .env file dotenv::dotenv().ok(); // Initialize logging tracing_subscriber::fmt() .with_env_filter( tracing_subscriber::EnvFilter::try_from_default_env() .unwrap_or_else(|_| tracing_subscriber::EnvFilter::new("info")), ) .init(); let api_key = std::env::var("ANTHROPIC_API_KEY").expect("ANTHROPIC_API_KEY environment variable not set"); let client = AnthropicClient::new(&api_key, "claude-sonnet-4-20250514"); let worker = Worker::new(client); println!("πŸš€ Starting Worker..."); println!("πŸ’‘ Will cancel after 2 seconds\n"); // Get cancel sender before run (Mutable state) let cancel_tx = worker.cancel_sender(); // Task: Cancel after 2 seconds tokio::spawn(async move { tokio::time::sleep(Duration::from_secs(2)).await; println!("\nπŸ›‘ Cancelling worker..."); let _ = cancel_tx.send(()).await; }); println!("πŸ“‘ Sending request to LLM..."); // Mutable::run consumes self β†’ (Locked, WorkerResult) match worker.run("Tell me a very long story about a brave knight. Make it as detailed as possible with many paragraphs.").await { Ok((_locked, WorkerResult::Finished)) => { println!("βœ… Task completed normally"); } Ok((_locked, WorkerResult::Paused)) => { println!("⏸️ Task paused"); } Ok((_locked, WorkerResult::LimitReached)) => { println!("πŸ”’ Turn limit reached"); } Err(e) => { println!("❌ Task error: {}", e); } } println!("\n✨ Demo complete!"); Ok(()) }