[−][src]Trait async_std::stream::Product

pub trait Product<A = Self>: Sized {
    fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>>
    where
        S: Stream<Item = A> + 'a;
}
This is supported on unstable only.

Trait to represent types that can be created by multiplying the elements of a stream.

This trait is used to implement the product method on streams. Types which implement the trait can be generated by the product method. Like FromStream this trait should rarely be called directly and instead interacted with through Stream::product.

Required methods

ⓘImportant traits for Pin<P>
fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>> where
    S: Stream<Item = A> + 'a, 

This is supported on unstable only.

Method which takes a stream and generates Self from the elements by multiplying the items.

Loading content...

Implementations on Foreign Types

impl Product<i8> for i8[src]

impl<'a> Product<&'a i8> for i8[src]

impl Product<i16> for i16[src]

impl<'a> Product<&'a i16> for i16[src]

impl Product<i32> for i32[src]

impl<'a> Product<&'a i32> for i32[src]

impl Product<i64> for i64[src]

impl<'a> Product<&'a i64> for i64[src]

impl Product<i128> for i128[src]

impl<'a> Product<&'a i128> for i128[src]

impl Product<isize> for isize[src]

impl<'a> Product<&'a isize> for isize[src]

impl Product<u8> for u8[src]

impl<'a> Product<&'a u8> for u8[src]

impl Product<u16> for u16[src]

impl<'a> Product<&'a u16> for u16[src]

impl Product<u32> for u32[src]

impl<'a> Product<&'a u32> for u32[src]

impl Product<u64> for u64[src]

impl<'a> Product<&'a u64> for u64[src]

impl Product<u128> for u128[src]

impl<'a> Product<&'a u128> for u128[src]

impl Product<usize> for usize[src]

impl<'a> Product<&'a usize> for usize[src]

impl Product<Wrapping<i8>> for Wrapping<i8>[src]

impl<'a> Product<&'a Wrapping<i8>> for Wrapping<i8>[src]

impl Product<Wrapping<i16>> for Wrapping<i16>[src]

impl<'a> Product<&'a Wrapping<i16>> for Wrapping<i16>[src]

impl Product<Wrapping<i32>> for Wrapping<i32>[src]

impl<'a> Product<&'a Wrapping<i32>> for Wrapping<i32>[src]

impl Product<Wrapping<i64>> for Wrapping<i64>[src]

impl<'a> Product<&'a Wrapping<i64>> for Wrapping<i64>[src]

impl Product<Wrapping<i128>> for Wrapping<i128>[src]

impl<'a> Product<&'a Wrapping<i128>> for Wrapping<i128>[src]

impl Product<Wrapping<isize>> for Wrapping<isize>[src]

impl<'a> Product<&'a Wrapping<isize>> for Wrapping<isize>[src]

impl Product<Wrapping<u8>> for Wrapping<u8>[src]

impl<'a> Product<&'a Wrapping<u8>> for Wrapping<u8>[src]

impl Product<Wrapping<u16>> for Wrapping<u16>[src]

impl<'a> Product<&'a Wrapping<u16>> for Wrapping<u16>[src]

impl Product<Wrapping<u32>> for Wrapping<u32>[src]

impl<'a> Product<&'a Wrapping<u32>> for Wrapping<u32>[src]

impl Product<Wrapping<u64>> for Wrapping<u64>[src]

impl<'a> Product<&'a Wrapping<u64>> for Wrapping<u64>[src]

impl Product<Wrapping<u128>> for Wrapping<u128>[src]

impl<'a> Product<&'a Wrapping<u128>> for Wrapping<u128>[src]

impl Product<Wrapping<usize>> for Wrapping<usize>[src]

impl<'a> Product<&'a Wrapping<usize>> for Wrapping<usize>[src]

impl Product<f32> for f32[src]

impl<'a> Product<&'a f32> for f32[src]

impl Product<f64> for f64[src]

impl<'a> Product<&'a f64> for f64[src]

impl<T, U, E> Product<Result<U, E>> for Result<T, E> where
    T: Product<U>, [src]

ⓘImportant traits for Pin<P>
fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Result<T, E>> + 'a>> where
    S: Stream<Item = Result<U, E>> + 'a, [src]

This is supported on unstable and unstable only.

Takes each element in the Stream: if it is an Err, no further elements are taken, and the Err is returned. Should no Err occur, the product of all elements is returned.

Examples

This multiplies every integer in a vector, rejecting the product if a negative element is encountered:

use async_std::prelude::*;
use async_std::stream;

let v = stream::from_iter(vec![1, 2, 4]);
let res: Result<i32, &'static str> = v.map(|x|
    if x < 0 {
        Err("Negative element found")
    } else {
        Ok(x)
    }).product().await;
assert_eq!(res, Ok(8));

impl<T, U> Product<Option<U>> for Option<T> where
    T: Product<U>, [src]

ⓘImportant traits for Pin<P>
fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Option<T>> + 'a>> where
    S: Stream<Item = Option<U>> + 'a, [src]

This is supported on unstable and unstable only.

Takes each element in the Stream: if it is a None, no further elements are taken, and the None is returned. Should no None occur, the product of all elements is returned.

Examples

This multiplies every integer in a vector, rejecting the product if a negative element is encountered:

use async_std::prelude::*;
use async_std::stream;

let v = stream::from_iter(vec![1, 2, 4]);
let prod: Option<i32> = v.map(|x|
    if x < 0 {
        None
    } else {
        Some(x)
    }).product().await;
assert_eq!(prod, Some(8));
Loading content...

Implementors

Loading content...