vortex::stream

Trait ArrayStreamExt

Source 
pub trait ArrayStreamExt: ArrayStream {
    // Provided methods
    fn collect_chunked(
        self,
    ) -> impl Future<Output = Result<ChunkedArray, VortexError>>
       where Self: Sized { ... }
    fn take_rows(self, indices: Array) -> Result<impl ArrayStream, VortexError>
       where Self: Sized { ... }
}

Provided Methods§

Source

fn collect_chunked( self, ) -> impl Future<Output = Result<ChunkedArray, VortexError>>
where Self: Sized,

Source

fn take_rows(self, indices: Array) -> Result<impl ArrayStream, VortexError>
where Self: Sized,

Implementors§

Source§

impl<R> ArrayStreamExt for R
where R: ArrayStream,