Struct StreamingPipeline 

pub struct StreamingPipeline { /* private fields */ }

Composable bounded-memory point-cloud stream.

Implementations

impl StreamingPipeline

pub fn new( source: impl BoundedSpatialRecordSource + 'static, source_id: impl Into<String>, ) -> RecordsResult<Self>

Starts a workflow and meters chunks read from the original source.

pub fn schema(&self) -> &SchemaDescriptor

Returns the output schema.

pub fn cancellation_token(&self) -> CancellationToken

Returns the shared cooperative cancellation token.

pub fn crop( self, min: [f32; 3], max: [f32; 3], invert: bool, ) -> RecordsResult<Self>

Adds an inclusive axis-aligned crop.

pub fn transform(self, transform: Mat4<f32>) -> RecordsResult<Self>

Adds an affine position/normal transform.

pub fn voxel(self, config: StreamingVoxelConfig) -> RecordsResult<Self>

Adds deterministic global voxel aggregation backed by bounded spool storage.

pub fn run_to_sink( self, sink: &mut dyn BoundedSpatialRecordSink, ) -> RecordsResult<StreamingReceipt>

Drains the workflow into a synchronous bounded sink and returns its receipt.

Trait Implementations

impl IntoIterator for StreamingPipeline

type Item = Result<SpatialRecordChunk, RecordsError>

The type of the elements being iterated over.

type IntoIter = StreamingPipelineIter

Which kind of iterator are we turning this into?

fn into_iter(self) -> Self::IntoIter

Creates an iterator from a value.