Struct SharedLifecycleEmitter 

pub struct SharedLifecycleEmitter { /* private fields */ }

Shared lifecycle state for assistant text, reasoning, and model-emitted tool calls.

Implementations

impl SharedLifecycleEmitter

pub fn next_item_id(&mut self) -> String

Generate the next unique item ID for lifecycle events.

pub fn emit_completed_agent_message(&mut self, text: &str)

Emit a completed agent message event with the full text.

pub fn replace_assistant_text(&mut self, text: &str) -> bool

Replace the current assistant streaming text. Returns true if the text changed.

pub fn assistant_started(&self) -> bool

Whether the assistant text stream has been started.

pub fn assistant_len(&self) -> usize

Length of the accumulated assistant text in bytes.

pub fn append_assistant_delta(&mut self, delta: &str) -> bool

Append a delta to the assistant text stream. Returns true if content was added.

pub fn emit_assistant_snapshot(&mut self, item_id: Option<String>) -> bool

Emit a snapshot of the current assistant text as an item event.

pub fn complete_assistant_stream(&mut self) -> bool

Complete the assistant text stream, emitting a final completed event.

pub fn emit_completed_reasoning(&mut self, text: &str)

Emit a completed reasoning event with the full text.

pub fn replace_reasoning_text(&mut self, text: &str) -> bool

Replace the current reasoning streaming text. Returns true if the text changed.

pub fn append_reasoning_delta(&mut self, delta: &str) -> bool

Append a delta to the reasoning text stream. Returns true if content was added.

pub fn set_reasoning_stage(&mut self, stage: Option<String>) -> bool

Update the reasoning stage label. Returns true if the stage changed.

pub fn reasoning_len(&self) -> usize

Length of the accumulated reasoning text in bytes.

pub fn reasoning_started(&self) -> bool

Whether the reasoning text stream has been started.

pub fn emit_reasoning_snapshot(&mut self, item_id: Option<String>) -> bool

Emit a snapshot of the current reasoning text as an item event.

pub fn emit_reasoning_stage_update(&mut self) -> bool

Emit an update event reflecting the current reasoning stage.

pub fn complete_reasoning_stream(&mut self) -> bool

Complete the reasoning text stream, emitting a final completed event.

pub fn start_tool_call( &mut self, call_id: &str, tool_name: Option<String>, item_id: Option<String>, ) -> bool

Start tracking a tool call, emitting an item-started event.

pub fn append_tool_call_delta( &mut self, call_id: &str, delta: &str, tool_name: Option<String>, item_id: Option<String>, ) -> bool

Append an argument delta to an in-progress tool call.

pub fn complete_tool_call( &mut self, call_id: &str, status: ToolCallStatus, outcome: Option<ToolOutcome>, ) -> bool

pub fn tool_call_item_id(&self, call_id: &str) -> Option<&str>

pub fn sync_tool_call_arguments( &mut self, call_id: &str, arguments: &str, tool_name: Option<String>, item_id: Option<String>, ) -> bool

pub fn complete_open_items(&mut self)

pub fn complete_open_text_items(&mut self)

pub fn complete_open_items_with_tool_status(&mut self, status: ToolCallStatus)

pub fn complete_open_tool_calls_with_status(&mut self, status: ToolCallStatus)

pub fn flush_open_tool_call_arguments(&mut self)

Emit a final item.updated carrying the full accumulated arguments for each open tool call, bypassing the intermediate-update throttle.

Tool calls remain open (not completed); callers complete them via Self::complete_tool_call when execution finishes. This guarantees the authoritative streamed arguments are visible after streaming ends even when intermediate deltas were throttled (e.g. small tool calls whose completing delta fell below the byte threshold). Updates that would carry the same length as the last emitted snapshot are skipped to avoid redundant events for large tool calls whose last intermediate update already captured the full arguments.

pub fn drain_events(&mut self) -> Vec<ThreadEvent>

Trait Implementations

impl Debug for SharedLifecycleEmitter

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

Formats the value using the given formatter.

impl Default for SharedLifecycleEmitter

fn default() -> Self

Returns the “default value” for a type.