synth-ai-core 0.3.0

Rust core for Synth AI SDKs - API client, streaming, tracing, and tunnels
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
33
34
35
36

//! Streaming framework for job events.
//!
//! This module provides a framework for streaming events from running jobs:
//! - Stream types and messages
//! - Configurable filtering and deduplication
//! - Endpoint configuration for different job types
//! - Handlers for processing stream messages
//! - Job streamer for polling and dispatching

pub mod config;
pub mod endpoints;
pub mod handler;
pub mod streamer;
pub mod types;

pub use config::StreamConfig;
pub use endpoints::StreamEndpoints;
pub use handler::{
    BufferedHandler, CallbackHandler, FilteredHandler, JsonHandler, MultiHandler, StreamHandler,
};
pub use streamer::JobStreamer;
pub use types::{StreamMessage, StreamType};

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn test_module_exports() {
        // Verify all types are accessible
        let _ = StreamType::Events;
        let _ = StreamConfig::default();
        let _ = StreamEndpoints::learning("test");
        let _ = BufferedHandler::new();
    }
}