Trait ArrayMinMaxTryStream 

pub trait ArrayMinMaxTryStream<'a, T, E>
where
    T: HasAfEnum + HasArrayExt + Copy + Default + Send + 'a + DType + Max + Min,
    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>>,
{
    // Provided methods
    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.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl<'a, T, E, S> ArrayMinMaxTryStream<'a, T, E> for S

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