Trait afarray::ArrayProductTryStream

pub trait ArrayProductTryStream<'a, T, E> where
    T: HasAfEnum + HasArrayExt + Copy + Default + Send + 'a,
    E: Send + 'a,
    T::ProductOutType: DType + Product + Copy + Default + Send + 'a,
    Self: Stream<Item = Result<ArrayExt<T>, E>> + Sized + Send + Unpin + 'a,
    ArrayExt<T>: ArrayInstanceProduct<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> { ... }
}

Trait to reduce the product of 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>

Compute the product of each stride of a [Stream] of ArrayExts.

Implementors

impl<'a, T, E, S> ArrayProductTryStream<'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::ProductOutType: DType + Product + Copy + Default + Send + 'a,
    ArrayExt<T>: ArrayInstanceProduct<T>,