Trait afarray::ArrayTryStream [−][src]
pub trait ArrayTryStream<'a, T, E> where
T: HasAfEnum + HasArrayExt + Copy + Default + Send + 'a,
E: Send + 'a,
T::AggregateOutType: DType + Sum + Copy + Default + Send + 'a,
T::ProductOutType: DType + Product + Copy + Default + Send + 'a,
Self: Stream<Item = Result<ArrayExt<T>, E>> + Sized + Send + Unpin + 'a,
ArrayExt<T>: ArrayInstanceReduce<T> + From<Array<T>>, {
fn reduce_product(
self,
block_size: usize,
stride: u64
) -> Box<dyn Stream<Item = Result<ArrayExt<T::ProductOutType>, E>> + Send + Unpin + 'a> { ... }
fn reduce_sum(
self,
block_size: usize,
stride: u64
) -> Box<dyn Stream<Item = Result<ArrayExt<T::AggregateOutType>, E>> + Send + Unpin + 'a> { ... }
fn resize(self, block_size: usize) -> Resize<Self, T> { ... }
}Expand description
Methods for handling a [Stream] of ArrayExts.
Provided methods
fn reduce_product(
self,
block_size: usize,
stride: u64
) -> Box<dyn Stream<Item = Result<ArrayExt<T::ProductOutType>, E>> + Send + Unpin + 'a>
fn reduce_product(
self,
block_size: usize,
stride: u64
) -> Box<dyn Stream<Item = Result<ArrayExt<T::ProductOutType>, E>> + Send + Unpin + 'a>
Compute the product of each stride of a [Stream] of ArrayExts.
fn reduce_sum(
self,
block_size: usize,
stride: u64
) -> Box<dyn Stream<Item = Result<ArrayExt<T::AggregateOutType>, E>> + Send + Unpin + 'a>
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.