Trait afarray::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>>, {
    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.

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>,