Struct Timeline 

pub struct Timeline { /* private fields */ }

イベントストリームの管理とハンドラへのディスパッチ

LLMからのイベントを受信し、登録されたハンドラに振り分けます。 ブロック系イベントはスコープ管理付きで処理されます。

Examples

use llm_worker::{Timeline, Handler, TextBlockKind, TextBlockEvent};

struct MyHandler;
impl Handler<TextBlockKind> for MyHandler {
    type Scope = String;
    fn on_event(&mut self, buffer: &mut String, event: &TextBlockEvent) {
        if let TextBlockEvent::Delta(text) = event {
            buffer.push_str(text);
        }
    }
}

let mut timeline = Timeline::new();
timeline.on_text_block(MyHandler);

サポートするイベント種別

• メタ系: Usage, Ping, Status, Error
• ブロック系: TextBlock, ThinkingBlock, ToolUseBlock

Implementations

impl Timeline

pub fn new() -> Self

pub fn on_usage<H>(&mut self, handler: H) -> &mut Self

where H: Handler<UsageKind> + Send + Sync + 'static, H::Scope: Send + Sync,

UsageKind用のHandlerを登録

pub fn on_ping<H>(&mut self, handler: H) -> &mut Self

where H: Handler<PingKind> + Send + Sync + 'static, H::Scope: Send + Sync,

PingKind用のHandlerを登録

pub fn on_status<H>(&mut self, handler: H) -> &mut Self

where H: Handler<StatusKind> + Send + Sync + 'static, H::Scope: Send + Sync,

StatusKind用のHandlerを登録

pub fn on_error<H>(&mut self, handler: H) -> &mut Self

where H: Handler<ErrorKind> + Send + Sync + 'static, H::Scope: Send + Sync,

ErrorKind用のHandlerを登録

pub fn on_text_block<H>(&mut self, handler: H) -> &mut Self

where H: Handler<TextBlockKind> + Send + Sync + 'static, H::Scope: Send + Sync,

TextBlockKind用のHandlerを登録

pub fn on_thinking_block<H>(&mut self, handler: H) -> &mut Self

where H: Handler<ThinkingBlockKind> + Send + Sync + 'static, H::Scope: Send + Sync,

ThinkingBlockKind用のHandlerを登録

pub fn on_tool_use_block<H>(&mut self, handler: H) -> &mut Self

where H: Handler<ToolUseBlockKind> + Send + Sync + 'static, H::Scope: Send + Sync,

ToolUseBlockKind用のHandlerを登録

pub fn dispatch(&mut self, event: &Event)

メインのディスパッチエントリポイント

pub fn current_block(&self) -> Option<BlockType>

現在アクティブなブロックタイプを取得

pub fn abort_current_block(&mut self)

現在アクティブなブロックを中断する

キャンセルやエラー時に呼び出し、進行中のブロックに対して BlockAbortイベントを発火してスコープをクリーンアップする。

Trait Implementations

impl Default for Timeline

fn default() -> Self

Returns the “default value” for a type.