Struct StreamOutput 

pub struct StreamOutput { /* private fields */ }

Incremental concatenation of chunk outputs.

Each chunk’s data is folded in and the chunk dropped, keeping peak memory proportional to the final output rather than O(n_chunks x chunk_size). Non-tensor outputs do not concatenate; the last one wins (a chain ending in an aggregate produces exactly one).

Implementations

impl StreamOutput

pub fn new() -> Self

An empty accumulator; equivalent to Default::default().

pub fn push(&mut self, output: Value)

Fold one chunk’s output in.

pub fn finish(self) -> Value

The concatenated result, its first dimension corrected to the total number of rows. Value::Empty if nothing was pushed.

Trait Implementations

impl Default for StreamOutput

fn default() -> StreamOutput

Returns the “default value” for a type.