liteforge 0.2.5

Rust SDK for LiteForge - LLM completions via OpenAI-compatible API
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

//! Event system for reactive programming patterns.
//!
//! Provides an event bus for publishing and subscribing to events
//! across different components of an application.
//!
//! # Example
//!
//! ```
//! use liteforge::events::{EventBus, Event, EventType};
//!
//! #[tokio::main]
//! async fn main() {
//!     let bus = EventBus::new();
//!
//!     // Subscribe to events
//!     let mut rx = bus.subscribe(EventType::ToolCall);
//!
//!     // Publish an event
//!     bus.publish(Event::tool_call("calculator", r#"{"op": "add"}"#));
//!
//!     // Receive event
//!     if let Ok(event) = rx.try_recv() {
//!         println!("Received: {:?}", event.event_type);
//!     }
//! }
//! ```

mod bus;
mod types;

pub use bus::{EventBus, Subscription};
pub use types::{Event, EventData, EventType};