Struct VecStreamEmitter 

pub struct VecStreamEmitter { /* private fields */ }

Vector-based event emitter for collecting events.

Implementations

impl VecStreamEmitter

pub fn new() -> Self

Creates a new vector emitter.

pub fn into_events(self) -> Vec<ResponseStreamEvent>

Consumes and returns the collected events.

Trait Implementations

impl Debug for VecStreamEmitter

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

Formats the value using the given formatter.

impl Default for VecStreamEmitter

fn default() -> Self

Returns the “default value” for a type.

impl StreamEventEmitter for VecStreamEmitter

fn emit(&mut self, event: ResponseStreamEvent)

Emit a streaming event.

fn response_created(&mut self, response: Response)

Emit a response created event.

fn response_in_progress(&mut self, response: Response)

Emit a response in progress event.

fn response_completed(&mut self, response: Response)

Emit a response completed event.

fn response_failed(&mut self, response: Response)

Emit a response failed event.

fn output_item_added( &mut self, response_id: &ResponseId, output_index: usize, item: OutputItem, )

Emit an output item added event.

fn output_item_done( &mut self, response_id: &ResponseId, output_index: usize, item: OutputItem, )

Emit an output item done event.

fn output_text_delta( &mut self, response_id: &ResponseId, item_id: &str, output_index: usize, content_index: usize, delta: &str, )

Emit a text delta event.

fn reasoning_delta( &mut self, response_id: &ResponseId, item_id: &str, output_index: usize, delta: &str, )

Emit a reasoning delta event.