package chatoyant

  1. Overview
  2. Docs

Module Chatoyant_core.StreamSource

Provider-neutral streaming accumulator.

Raw providers decode their own SSE/WebSocket events first, then can map deltas into these frames. The accumulator owns cross-provider invariants: stable text concatenation, fragmented tool-call argument merging, usage provenance, finish reason, and timing/token-speed derivation.

Sourcetype tool_call_delta = {
  1. index : int;
  2. id : string option;
  3. name : string option;
  4. arguments_delta : string;
  5. raw : Chatoyant_runtime.Json.t option;
}
Sourcetype frame = {
  1. content_delta : string option;
  2. reasoning_delta : string option;
  3. tool_call_deltas : tool_call_delta list;
  4. usage : Chatoyant_tokens.Cost.usage option;
  5. usage_source : Chatoyant_tokens.Cost.source;
  6. finish_reason : string option;
  7. raw : Chatoyant_runtime.Json.t option;
}
Sourcetype state
Sourceval empty : state
Sourceval apply : state -> frame -> state
Sourceval content : state -> string
Sourceval reasoning_content : state -> string
Sourceval finish_reason : state -> string option
Sourceval note_first_token : now_ms:int -> state -> state
Sourceval to_generation : provider:Chatoyant_provider.Provider.id -> model:string -> started_ms:int -> finished_ms:int -> state -> Result.generation
Sourceval frame_to_json : frame -> Chatoyant_runtime.Json.t
Sourceval state_to_json : state -> Chatoyant_runtime.Json.t