Trait afarray::ArraySumTryStream
source · [−]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> { ... }
}
Expand description
Trait to reduce the sum of a [Stream
] of ArrayExt
s.