Struct CollectorSink 

pub struct CollectorSink<T> { /* private fields */ }

A simple collector sink that stores all items in memory.

Implementations

impl<T> CollectorSink<T>

pub fn new() -> Self

Creates a new collector sink.

pub fn with_capacity(capacity: usize) -> Self

Creates a collector with pre-allocated capacity.

pub fn into_items(self) -> Vec<T>

Returns the collected items.

pub fn items(&self) -> &[T]

Returns references to collected items.

pub fn errors(&self) -> &[StreamError]

Returns collected errors.

pub fn summary(&self) -> Option<&StreamSummary>

Returns the stream summary if generation completed.

Trait Implementations

impl<T> Default for CollectorSink<T>

fn default() -> Self

Returns the “default value” for a type.

impl<T: Send> StreamingSink<T> for CollectorSink<T>

fn process(&mut self, event: StreamEvent<T>) -> SynthResult<()>

Processes a stream event.

fn flush(&mut self) -> SynthResult<()>

Flushes any buffered data.

fn close(self) -> SynthResult<()>

Closes the sink and releases resources.

fn items_processed(&self) -> u64

Returns the number of items processed.