Trait SequentialStream 

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

Required Methods

fn dtype(&self) -> &DType

Implementors

impl SequentialStream for SendableSequentialStream

impl<S> SequentialStream for SequentialStreamAdapter<S>

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