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;
}

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

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

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

fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>> where
    S: Stream<Item = i8> + 'a, 

impl<'a> Product<&'a i8> for i8

fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>> where
    S: Stream<Item = &'a i8> + 'b, 

impl Product<i16> for i16

fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>> where
    S: Stream<Item = i16> + 'a, 

impl<'a> Product<&'a i16> for i16

fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>> where
    S: Stream<Item = &'a i16> + 'b, 

impl Product<i32> for i32

fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>> where
    S: Stream<Item = i32> + 'a, 

impl<'a> Product<&'a i32> for i32

fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>> where
    S: Stream<Item = &'a i32> + 'b, 

impl Product<i64> for i64

fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>> where
    S: Stream<Item = i64> + 'a, 

impl<'a> Product<&'a i64> for i64

fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>> where
    S: Stream<Item = &'a i64> + 'b, 

impl Product<i128> for i128

fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>> where
    S: Stream<Item = i128> + 'a, 

impl<'a> Product<&'a i128> for i128

fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>> where
    S: Stream<Item = &'a i128> + 'b, 

impl Product<isize> for isize

fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>> where
    S: Stream<Item = isize> + 'a, 

impl<'a> Product<&'a isize> for isize

fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>> where
    S: Stream<Item = &'a isize> + 'b, 

impl Product<u8> for u8

fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>> where
    S: Stream<Item = u8> + 'a, 

impl<'a> Product<&'a u8> for u8

fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>> where
    S: Stream<Item = &'a u8> + 'b, 

impl Product<u16> for u16

fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>> where
    S: Stream<Item = u16> + 'a, 

impl<'a> Product<&'a u16> for u16

fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>> where
    S: Stream<Item = &'a u16> + 'b, 

impl Product<u32> for u32

fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>> where
    S: Stream<Item = u32> + 'a, 

impl<'a> Product<&'a u32> for u32

fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>> where
    S: Stream<Item = &'a u32> + 'b, 

impl Product<u64> for u64

fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>> where
    S: Stream<Item = u64> + 'a, 

impl<'a> Product<&'a u64> for u64

fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>> where
    S: Stream<Item = &'a u64> + 'b, 

impl Product<u128> for u128

fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>> where
    S: Stream<Item = u128> + 'a, 

impl<'a> Product<&'a u128> for u128

fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>> where
    S: Stream<Item = &'a u128> + 'b, 

impl Product<usize> for usize

fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>> where
    S: Stream<Item = usize> + 'a, 

impl<'a> Product<&'a usize> for usize

fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>> where
    S: Stream<Item = &'a usize> + 'b, 

impl Product<Wrapping<i8>> for Wrapping<i8>

fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>> where
    S: Stream<Item = Wrapping<i8>> + 'a, 

impl<'a> Product<&'a Wrapping<i8>> for Wrapping<i8>

fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>> where
    S: Stream<Item = &'a Wrapping<i8>> + 'b, 

impl Product<Wrapping<i16>> for Wrapping<i16>

fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>> where
    S: Stream<Item = Wrapping<i16>> + 'a, 

impl<'a> Product<&'a Wrapping<i16>> for Wrapping<i16>

fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>> where
    S: Stream<Item = &'a Wrapping<i16>> + 'b, 

impl Product<Wrapping<i32>> for Wrapping<i32>

fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>> where
    S: Stream<Item = Wrapping<i32>> + 'a, 

impl<'a> Product<&'a Wrapping<i32>> for Wrapping<i32>

fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>> where
    S: Stream<Item = &'a Wrapping<i32>> + 'b, 

impl Product<Wrapping<i64>> for Wrapping<i64>

fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>> where
    S: Stream<Item = Wrapping<i64>> + 'a, 

impl<'a> Product<&'a Wrapping<i64>> for Wrapping<i64>

fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>> where
    S: Stream<Item = &'a Wrapping<i64>> + 'b, 

impl Product<Wrapping<i128>> for Wrapping<i128>

fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>> where
    S: Stream<Item = Wrapping<i128>> + 'a, 

impl<'a> Product<&'a Wrapping<i128>> for Wrapping<i128>

fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>> where
    S: Stream<Item = &'a Wrapping<i128>> + 'b, 

impl Product<Wrapping<isize>> for Wrapping<isize>

fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>> where
    S: Stream<Item = Wrapping<isize>> + 'a, 

impl<'a> Product<&'a Wrapping<isize>> for Wrapping<isize>

fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>> where
    S: Stream<Item = &'a Wrapping<isize>> + 'b, 

impl Product<Wrapping<u8>> for Wrapping<u8>

fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>> where
    S: Stream<Item = Wrapping<u8>> + 'a, 

impl<'a> Product<&'a Wrapping<u8>> for Wrapping<u8>

fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>> where
    S: Stream<Item = &'a Wrapping<u8>> + 'b, 

impl Product<Wrapping<u16>> for Wrapping<u16>

fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>> where
    S: Stream<Item = Wrapping<u16>> + 'a, 

impl<'a> Product<&'a Wrapping<u16>> for Wrapping<u16>

fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>> where
    S: Stream<Item = &'a Wrapping<u16>> + 'b, 

impl Product<Wrapping<u32>> for Wrapping<u32>

fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>> where
    S: Stream<Item = Wrapping<u32>> + 'a, 

impl<'a> Product<&'a Wrapping<u32>> for Wrapping<u32>

fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>> where
    S: Stream<Item = &'a Wrapping<u32>> + 'b, 

impl Product<Wrapping<u64>> for Wrapping<u64>

fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>> where
    S: Stream<Item = Wrapping<u64>> + 'a, 

impl<'a> Product<&'a Wrapping<u64>> for Wrapping<u64>

fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>> where
    S: Stream<Item = &'a Wrapping<u64>> + 'b, 

impl Product<Wrapping<u128>> for Wrapping<u128>

fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>> where
    S: Stream<Item = Wrapping<u128>> + 'a, 

impl<'a> Product<&'a Wrapping<u128>> for Wrapping<u128>

fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>> where
    S: Stream<Item = &'a Wrapping<u128>> + 'b, 

impl Product<Wrapping<usize>> for Wrapping<usize>

fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>> where
    S: Stream<Item = Wrapping<usize>> + 'a, 

impl<'a> Product<&'a Wrapping<usize>> for Wrapping<usize>

fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>> where
    S: Stream<Item = &'a Wrapping<usize>> + 'b, 

impl Product<f32> for f32

fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>> where
    S: Stream<Item = f32> + 'a, 

impl<'a> Product<&'a f32> for f32

fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>> where
    S: Stream<Item = &'a f32> + 'b, 

impl Product<f64> for f64

fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>> where
    S: Stream<Item = f64> + 'a, 

impl<'a> Product<&'a f64> for f64

fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>> where
    S: Stream<Item = &'a f64> + 'b, 

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

fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Result<T, E>> + 'a>> where
    S: Stream<Item = Result<U, E>> + 'a, 

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

fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Option<T>> + 'a>> where
    S: Stream<Item = Option<U>> + 'a, 

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