vortex_array::stream

Trait ArrayStreamExt

Source 
pub trait ArrayStreamExt: ArrayStream {
    // Provided methods
    fn boxed(self) -> SendableArrayStream
       where Self: Sized + Send + 'static { ... }
    fn read_all(self) -> impl Future<Output = VortexResult<ArrayRef>>
       where Self: Sized { ... }
}

Provided Methods§

Source

fn boxed(self) -> SendableArrayStream
where Self: Sized + Send + 'static,

Box the ArrayStream so that it can be sent between threads.

Source

fn read_all(self) -> impl Future<Output = VortexResult<ArrayRef>>
where Self: Sized,

Collect the stream into a single Array.

If the stream yields multiple chunks, they will be returned as a ChunkedArray.

Implementors§