Enum StreamChunk 

pub enum StreamChunk {
    Token(String),
    Thinking(String),
    Done(String),
    Error(String),
    Metrics {
        input_tokens: u64,
        output_tokens: u64,
    },
    McpConnected(String),
    McpError {
        server_name: String,
        error: String,
    },
    McpCallStart {
        tool: String,
        server: String,
        params: String,
    },
    McpCallComplete {
        result: String,
    },
    McpCallFailed {
        error: String,
    },
    InferStart {
        model: String,
        prompt: String,
        prompt_tokens: u32,
        max_tokens: u32,
    },
    InferTokens {
        output_tokens: u32,
    },
    InferComplete,
    ExecStart {
        command: String,
    },
    ExecComplete,
    FetchStart {
        url: String,
        method: String,
    },
    FetchComplete,
    AgentStart {
        goal: String,
    },
    AgentComplete,
    ProviderVerifying {
        provider: String,
        model: String,
    },
    ProviderVerified {
        provider: String,
        model: String,
        latency_ms: u64,
    },
    ProviderVerifyFailed {
        provider: String,
        error: String,
    },
    ProviderNotConfigured {
        provider: String,
    },
    McpPinging {
        server: String,
    },
    McpPinged {
        server: String,
        latency_ms: u64,
        tool_count: usize,
    },
    ProviderVerificationTimeout,
    NativeModelPullStarted {
        model: String,
    },
    NativeModelPullProgress {
        model: String,
        status: String,
        completed: u64,
        total: u64,
    },
    NativeModelPulled {
        model: String,
        path: String,
        size: u64,
    },
    NativeModelPullFailed {
        model: String,
        error: String,
    },
    NativeModelDeleted {
        model: String,
    },
    NativeModelDeleteFailed {
        model: String,
        error: String,
    },
    NativeModelsRefreshed {
        count: usize,
    },
}

Chunk of streaming response for real-time display

Variants

Token(String)

Text token from the model

Thinking(String)

Thinking/reasoning content (Claude extended thinking)

Done(String)

Stream completed successfully with final text

Error(String)

Stream failed with error

Metrics

Token usage metrics (sent after completion)

Fields

input_tokens: u64

output_tokens: u64

McpConnected(String)

MCP server connected successfully

McpError

MCP server connection failed

Fields

server_name: String

error: String

McpCallStart

MCP tool call started (for inline visualization)

Fields

tool: String

server: String

params: String

McpCallComplete

MCP tool call completed successfully

Fields

result: String

McpCallFailed

MCP tool call failed

Fields

error: String

InferStart

Infer stream started (for inline visualization)

Fields

model: String

prompt: String

The user prompt text (for TaskBox::Infer display)

prompt_tokens: u32

max_tokens: u32

InferTokens

Infer stream token count update

Fields

output_tokens: u32

InferComplete

Infer stream completed

ExecStart

Shell command started (for activity stack)

Fields

command: String

ExecComplete

Shell command completed

FetchStart

HTTP fetch started (for activity stack)

Fields

url: String

method: String

FetchComplete

HTTP fetch completed

AgentStart

Agent loop started (for activity stack)

Fields

goal: String

AgentComplete

Agent loop completed

ProviderVerifying

Provider verification started

Fields

provider: String

model: String

ProviderVerified

Provider verification succeeded

Fields

provider: String

model: String

latency_ms: u64

ProviderVerifyFailed

Provider verification failed

Fields

provider: String

error: String

ProviderNotConfigured

Provider not configured (no API key set)

Fields

provider: String

McpPinging

MCP server ping started

Fields

server: String

McpPinged

MCP server ping succeeded

Fields

server: String

latency_ms: u64

tool_count: usize

ProviderVerificationTimeout

All provider verifications timed out (no providers available)

NativeModelPullStarted

Native model pull started

Fields

model: String

NativeModelPullProgress

Native model pull progress update

Fields

model: String

status: String

completed: u64

total: u64

NativeModelPulled

Native model pull completed successfully

Fields

model: String

path: String

size: u64

NativeModelPullFailed

Native model pull failed

Fields

model: String

error: String

NativeModelDeleted

Native model deleted

Fields

model: String

NativeModelDeleteFailed

Native model delete failed

Fields

model: String

error: String

NativeModelsRefreshed

Native models list refreshed

Fields

count: usize

Trait Implementations

impl Clone for StreamChunk

fn clone(&self) -> StreamChunk

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamChunk

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

Formats the value using the given formatter.