Trait ArraySumTryStream 

pub trait ArraySumTryStream<'a, T, E>
where
    T: HasAfEnum + HasArrayExt + Copy + Default + Send + 'a,
    E: Send + 'a,
    T::AggregateOutType: DType + Sum + Copy + Default + Send + 'a,
    Self: Stream<Item = Result<ArrayExt<T>, E>> + Sized + Send + Unpin + 'a,
    ArrayExt<T>: ArrayInstanceSum<T> + From<Array<T>>,
{
    // Provided method
    fn reduce_sum(
        self,
        block_size: usize,
        stride: u64,
    ) -> Box<dyn Stream<Item = Result<ArrayExt<T::AggregateOutType>, E>> + Send + Unpin + 'a> { ... }
}

Trait to reduce the sum of a Stream of ArrayExts.

Provided Methods

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

Compute the sum 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> ArraySumTryStream<'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, T::AggregateOutType: DType + Sum + Copy + Default + Send + 'a, ArrayExt<T>: ArrayInstanceSum<T>,