Skip to main content

Module streaming

Module streaming 

Source
Expand description

§投機的ストリーミング検証モジュール (SSE Realtime Interceptor)

System 2 (上位 LLM) からの SSE (Server-Sent Events) ストリーミングレスポンスに対し、 句読点 (「。」「\n」「!」「?」) 単位でリアルタイムに文境界をバッファリングし、 投機的 NLI ハルシネーション検証を並行して実行する。 不整合を検知した瞬間、ダウンストリームへの送信を即時切断し、安全なエラー・置換メッセージを 注入して安全にコネクションをクローズする。

Structs§

SentenceChunkBuffer
文境界バッファ。
SpeculativeStreamInterceptor
投機的ストリーム検証インターセプター。
StreamingVerifierConfig
ストリーミング検証設定。

Constants§

SENTENCE_DELIMITERS
文境界区切り文字。
TERMINATION_REPLACEMENT_MESSAGE
ストリーミング遮断時の置換メッセージ。

Functions§

extract_content_from_sse_line
SSE の data ペイロードからテキスト本文を抽出する簡易ヘルパー。
intercept_sse_stream
SSE ストリームをインターセプトし、文境界ごとの投機的ハルシネーション検証とサーキットブレークを行う。