open-agent-sdk 0.8.0

Production-ready Rust SDK for building AI agents with local OpenAI-compatible servers (LMStudio, Ollama, llama.cpp, vLLM). Features streaming, tools, hooks, retry logic, and comprehensive examples.
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

//! Streaming utilities for SSE parsing and stream accumulation.
//!
//! Two stages sit between the raw HTTP response and the [`StreamEvent`](crate::StreamEvent)s
//! a caller sees:
//!
//! ```text
//! Raw HTTP body (SSE)  ──parse_sse_stream──▶  Stream<OpenAIChunk>
//!                      ──StreamAccumulator──▶  Vec<StreamEvent>
//! ```
//!
//! - [`sse`] decodes the SSE wire format, buffering across arbitrary HTTP transport chunk
//!   boundaries so an event split mid-JSON (or mid-UTF-8) still parses.
//! - [`accumulator`] reassembles the per-chunk deltas — text, reasoning, and tool call
//!   arguments all arrive fragmented — and decides when a complete block can be emitted.
//!
//! The rationale for each stage lives with its code rather than being restated here.

// Real submodules rather than `include!` fragments: `cargo-mutants` walks `mod`
// declarations but does not expand `include!`, so fragment-backed code is invisible to the
// mutation gate. Re-exporting keeps `crate::utils::{StreamAccumulator, parse_sse_stream}`
// unchanged for callers.
mod accumulator;
mod sse;

pub use accumulator::StreamAccumulator;
pub use sse::parse_sse_stream;