Struct StreamingCollector 

pub struct StreamingCollector { /* private fields */ }

Streaming pipeline stage that collects all points into a PointCloud.

Useful for testing or as a terminal stage when the full cloud must eventually be materialized (e.g. after prior stages have filtered it down).

Implementations

impl StreamingCollector

pub fn new() -> Self

Create a new collector.

pub fn with_capacity(cap: usize) -> Self

Create a collector with pre-allocated capacity.

Trait Implementations

impl Default for StreamingCollector

fn default() -> Self

Returns the “default value” for a type.

impl StreamingPipeline<OPoint<f32, Const<3>>> for StreamingCollector

type Output = PointCloud<OPoint<f32, Const<3>>>

The type produced after all chunks have been processed.

fn process_chunk(&mut self, chunk: &[Point3f]) -> Result<()>

Ingest one chunk of items. Called repeatedly until the source is exhausted. chunk will never be empty.

fn finalize(self) -> Result<PointCloud<Point3f>>

Consume the pipeline and return the accumulated output.

fn memory_bytes(&self) -> usize

Estimated number of bytes currently held by this pipeline stage. Default returns 0; override to expose real memory usage.