Trait SequentialStream 

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

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 SequentialStream for SendableSequentialStream

impl<S> SequentialStream for SequentialStreamAdapter<S>

where S: Stream<Item = VortexResult<(SequenceId, ArrayRef)>>,