Enum Event 

pub enum Event {
    Ping(PingEvent),
    Usage(UsageEvent),
    Status(StatusEvent),
    Error(ErrorEvent),
    BlockStart(BlockStart),
    BlockDelta(BlockDelta),
    BlockStop(BlockStop),
    BlockAbort(BlockAbort),
}

LLMからのストリーミングイベント

各LLMプロバイダからのレスポンスは、このEventのストリームとして 統一的に処理されます。

イベントの種類

• メタイベント: Ping, Usage, Status, Error
• ブロックイベント: BlockStart, BlockDelta, BlockStop, BlockAbort

ブロックのライフサイクル

テキストやツール呼び出しは、BlockStart → BlockDelta(複数) → BlockStop の順序でイベントが発生します。

Variants

Ping(PingEvent)

ハートビート

Usage(UsageEvent)

トークン使用量

Status(StatusEvent)

ストリームのステータス変化

Error(ErrorEvent)

エラー発生

BlockStart(BlockStart)

ブロック開始（テキスト、ツール使用等）

BlockDelta(BlockDelta)

ブロックの差分データ

BlockStop(BlockStop)

ブロック正常終了

BlockAbort(BlockAbort)

ブロック中断

Implementations

impl Event

pub fn text_block_start(index: usize) -> Self

テキストブロック開始イベントを作成

pub fn text_delta(index: usize, text: impl Into<String>) -> Self

テキストデルタイベントを作成

pub fn text_block_stop(index: usize, stop_reason: Option<StopReason>) -> Self

テキストブロック停止イベントを作成

pub fn tool_use_start( index: usize, id: impl Into<String>, name: impl Into<String>, ) -> Self

ツール使用ブロック開始イベントを作成

pub fn tool_input_delta(index: usize, json: impl Into<String>) -> Self

ツール引数デルタイベントを作成

pub fn tool_use_stop(index: usize) -> Self

ツール使用ブロック停止イベントを作成

pub fn usage(input_tokens: u64, output_tokens: u64) -> Self

使用量イベントを作成

pub fn ping() -> Self

Pingイベントを作成

Trait Implementations

impl Clone for Event

fn clone(&self) -> Event

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Event

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Event

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<Event> for Event

fn from(value: Event) -> Self

Converts to this type from the input type.

impl PartialEq for Event

fn eq(&self, other: &Event) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for Event

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for Event