Trait afarray::ArrayMinMaxTryStream

pub trait ArrayMinMaxTryStream<'a, T, E> where
    T: HasAfEnum + HasArrayExt + Copy + Default + Send + 'a,
    T: DType + Max + Min + Copy + Default + Send + 'a,
    E: Send + 'a,
    Self: Stream<Item = Result<ArrayExt<T>, E>> + Sized + Send + Unpin + 'a,
    ArrayExt<T>: ArrayInstanceMinMax<T> + From<Array<T>> + From<Array<T::InType>>, {
    fn reduce_max(
        self, 
        block_size: usize, 
        stride: u64
    ) -> Box<dyn Stream<Item = Result<ArrayExt<T>, E>> + Send + Unpin + 'a> { ... }
    fn reduce_min(
        self, 
        block_size: usize, 
        stride: u64
    ) -> Box<dyn Stream<Item = Result<ArrayExt<T>, E>> + Send + Unpin + 'a> { ... }
}

Trait to reduce the sum of a [Stream] of ArrayExts.

Provided Methods

fn reduce_max(
    self,
    block_size: usize,
    stride: u64
) -> Box<dyn Stream<Item = Result<ArrayExt<T>, E>> + Send + Unpin + 'a>

Compute the maximum of each stride of a [Stream] of ArrayExts.

fn reduce_min(
    self,
    block_size: usize,
    stride: u64
) -> Box<dyn Stream<Item = Result<ArrayExt<T>, E>> + Send + Unpin + 'a>

Compute the minimum of each stride of a [Stream] of ArrayExts.

Implementors

impl<'a, T, E, S> ArrayMinMaxTryStream<'a, T, E> for S where
    T: HasAfEnum + HasArrayExt + Copy + Default + Send + 'a,
    T: DType + Max + Min + Copy + Default + Send + 'a,
    E: Send + 'a,
    S: Stream<Item = Result<ArrayExt<T>, E>> + Sized + Send + Unpin + 'a,
    ArrayExt<T>: ArrayInstanceMinMax<T> + From<Array<T::InType>>,