Trait afarray::ArrayTryStream

pub trait ArrayTryStream<'a, T, E> where
    T: HasAfEnum + HasArrayExt + Copy + Default + Send + 'a,
    E: Send + 'a,
    Self: Stream<Item = Result<ArrayExt<T>, E>> + Sized + Send + Unpin + 'a, {
    fn resize(self, block_size: usize) -> Resize<Self, T> { ... }
}

Methods for handling a [Stream] of ArrayExts.

Provided Methods

fn resize(self, block_size: usize) -> Resize<Self, T>

Change the block size of a stream of ArrayExts.

Implementors

impl<'a, T, E, S> ArrayTryStream<'a, T, E> for S where
    T: HasAfEnum + HasArrayExt + Copy + Default + Send + 'a,
    E: Send + 'a,
    S: Stream<Item = Result<ArrayExt<T>, E>> + Sized + Send + Unpin + 'a,