Trait ArrayStream 

pub trait ArrayStream: Stream<Item = VortexResult<ArrayRef>> {
    // Required method
    fn dtype(&self) -> &DType;
}

A stream of array chunks along with a DType.

Can be thought of as equivalent to Arrow’s RecordBatchReader.

Required Methods

fn dtype(&self) -> &DType

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl ArrayStream for SendableArrayStream

impl<S> ArrayStream for ArrayStreamAdapter<S>

where S: Stream<Item = VortexResult<ArrayRef>>,