Struct DrainedStream 

pub struct DrainedStream {
    pub items: Vec<Result<StreamedAssistantContent, CompletionError>>,
    pub choice: Vec<AssistantContent>,
    pub response: Option<StreamFinal>,
}

Available on crate feature test-utils and not (target_os=unknown and WebAssembly) only.

Everything the consumer observed from one full pipeline run: the yielded items in order, plus the aggregated choice and terminal record.

Fields

items: Vec<Result<StreamedAssistantContent, CompletionError>>

Every item the stream yielded, in order.

choice: Vec<AssistantContent>

The final aggregated assistant message.

response: Option<StreamFinal>

The normalized terminal record, absent on truncation or terminal error.

Implementations

impl DrainedStream

pub fn texts(&self) -> Vec<&str>

Text deltas yielded to the consumer, in order.

pub fn tool_call_names(&self) -> Vec<&str>

Names of the complete tool calls yielded to the consumer, in order.

pub fn unknown_values(&self) -> Vec<&Value>

Raw payloads of the Unknown passthrough items the stream yielded, in order.

pub fn error_count(&self) -> usize

Number of Err items the stream yielded.

pub fn final_count(&self) -> usize

Number of terminal records the stream yielded.

pub fn choice_texts(&self) -> Vec<&str>

Text blocks in the aggregated choice, in order.

pub fn choice_reasoning(&self) -> Vec<&Reasoning>

Reasoning items in the aggregated choice, in order.

pub fn choice_tool_call_names(&self) -> Vec<&str>

Names of the tool calls in the aggregated choice, in order.

Trait Implementations

impl Debug for DrainedStream

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

Formats the value using the given formatter.