ArrayProductTryStream

afarray

Trait ArrayProductTryStream 

Source 
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>>,
{
    // Provided method
    fn reduce_product(
        self,
        block_size: usize,
        stride: u64,
    ) -> Box<dyn Stream<Item = Result<ArrayExt<T::ProductOutType>, E>> + Send + Unpin + 'a> { ... }
}
Expand description

Trait to reduce the product of a Stream of ArrayExts.

Provided Methods§

Source

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.

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§

Source§

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