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

Implementors

impl ArrayStream for SendableArrayStream

impl<S> ArrayStream for ArrayStreamAdapter<S>

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