Trait WorkerSubscriber

Source

pub trait WorkerSubscriber: Send {
    type TextBlockScope: Default + Send + Sync;
    type ToolUseBlockScope: Default + Send + Sync;

    // Provided methods
    fn on_text_block(
        &mut self,
        scope: &mut Self::TextBlockScope,
        event: &TextBlockEvent,
    ) { ... }
    fn on_tool_use_block(
        &mut self,
        scope: &mut Self::ToolUseBlockScope,
        event: &ToolUseBlockEvent,
    ) { ... }
    fn on_usage(&mut self, event: &UsageEvent) { ... }
    fn on_status(&mut self, event: &StatusEvent) { ... }
    fn on_error(&mut self, event: &ErrorEvent) { ... }
    fn on_text_complete(&mut self, text: &str) { ... }
    fn on_tool_call_complete(&mut self, call: &ToolCall) { ... }
    fn on_turn_start(&mut self, turn: usize) { ... }
    fn on_turn_end(&mut self, turn: usize) { ... }
}

Expand description

LLMからのストリーミングイベントを購読するトレイト

Workerに登録すると、テキスト生成やツール呼び出しのイベントをリアルタイムで受信できます。UIへのストリーム表示に最適です。

§受信できるイベント

ブロックイベント: テキスト、ツール使用（スコープ付き）
メタイベント: 使用量、ステータス、エラー
完了イベント: テキスト完了、ツール呼び出し完了
ターン制御: ターン開始、ターン終了

§Examples

use llm_worker::subscriber::WorkerSubscriber;
use llm_worker::timeline::TextBlockEvent;

struct StreamPrinter;

impl WorkerSubscriber for StreamPrinter {
    type TextBlockScope = ();
    type ToolUseBlockScope = ();

    fn on_text_block(&mut self, _: &mut (), event: &TextBlockEvent) {
        if let TextBlockEvent::Delta(text) = event {
            print!("{}", text);  // リアルタイム出力
        }
    }

    fn on_text_complete(&mut self, text: &str) {
        println!("\n--- Complete: {} chars ---", text.len());
    }
}

// Workerに登録
worker.subscribe(StreamPrinter);