[−][src]Trait async_std::stream::Product
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
pub fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>>ⓘ where
S: Stream<Item = A> + 'a,
[src]
S: Stream<Item = A> + 'a,
Method which takes a stream and generates Self
from the elements by
multiplying the items.
Implementations on Foreign Types
impl Product<i8> for i8
[src]
pub fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>>ⓘ where
S: Stream<Item = i8> + 'a,
[src]
S: Stream<Item = i8> + 'a,
impl<'a> Product<&'a i8> for i8
[src]
pub fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>>ⓘ where
S: Stream<Item = &'a i8> + 'b,
[src]
S: Stream<Item = &'a i8> + 'b,
impl Product<i16> for i16
[src]
pub fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>>ⓘ where
S: Stream<Item = i16> + 'a,
[src]
S: Stream<Item = i16> + 'a,
impl<'a> Product<&'a i16> for i16
[src]
pub fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>>ⓘ where
S: Stream<Item = &'a i16> + 'b,
[src]
S: Stream<Item = &'a i16> + 'b,
impl Product<i32> for i32
[src]
pub fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>>ⓘ where
S: Stream<Item = i32> + 'a,
[src]
S: Stream<Item = i32> + 'a,
impl<'a> Product<&'a i32> for i32
[src]
pub fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>>ⓘ where
S: Stream<Item = &'a i32> + 'b,
[src]
S: Stream<Item = &'a i32> + 'b,
impl Product<i64> for i64
[src]
pub fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>>ⓘ where
S: Stream<Item = i64> + 'a,
[src]
S: Stream<Item = i64> + 'a,
impl<'a> Product<&'a i64> for i64
[src]
pub fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>>ⓘ where
S: Stream<Item = &'a i64> + 'b,
[src]
S: Stream<Item = &'a i64> + 'b,
impl Product<i128> for i128
[src]
pub fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>>ⓘ where
S: Stream<Item = i128> + 'a,
[src]
S: Stream<Item = i128> + 'a,
impl<'a> Product<&'a i128> for i128
[src]
pub fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>>ⓘ where
S: Stream<Item = &'a i128> + 'b,
[src]
S: Stream<Item = &'a i128> + 'b,
impl Product<isize> for isize
[src]
pub fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>>ⓘ where
S: Stream<Item = isize> + 'a,
[src]
S: Stream<Item = isize> + 'a,
impl<'a> Product<&'a isize> for isize
[src]
pub fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>>ⓘ where
S: Stream<Item = &'a isize> + 'b,
[src]
S: Stream<Item = &'a isize> + 'b,
impl Product<u8> for u8
[src]
pub fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>>ⓘ where
S: Stream<Item = u8> + 'a,
[src]
S: Stream<Item = u8> + 'a,
impl<'a> Product<&'a u8> for u8
[src]
pub fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>>ⓘ where
S: Stream<Item = &'a u8> + 'b,
[src]
S: Stream<Item = &'a u8> + 'b,
impl Product<u16> for u16
[src]
pub fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>>ⓘ where
S: Stream<Item = u16> + 'a,
[src]
S: Stream<Item = u16> + 'a,
impl<'a> Product<&'a u16> for u16
[src]
pub fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>>ⓘ where
S: Stream<Item = &'a u16> + 'b,
[src]
S: Stream<Item = &'a u16> + 'b,
impl Product<u32> for u32
[src]
pub fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>>ⓘ where
S: Stream<Item = u32> + 'a,
[src]
S: Stream<Item = u32> + 'a,
impl<'a> Product<&'a u32> for u32
[src]
pub fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>>ⓘ where
S: Stream<Item = &'a u32> + 'b,
[src]
S: Stream<Item = &'a u32> + 'b,
impl Product<u64> for u64
[src]
pub fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>>ⓘ where
S: Stream<Item = u64> + 'a,
[src]
S: Stream<Item = u64> + 'a,
impl<'a> Product<&'a u64> for u64
[src]
pub fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>>ⓘ where
S: Stream<Item = &'a u64> + 'b,
[src]
S: Stream<Item = &'a u64> + 'b,
impl Product<u128> for u128
[src]
pub fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>>ⓘ where
S: Stream<Item = u128> + 'a,
[src]
S: Stream<Item = u128> + 'a,
impl<'a> Product<&'a u128> for u128
[src]
pub fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>>ⓘ where
S: Stream<Item = &'a u128> + 'b,
[src]
S: Stream<Item = &'a u128> + 'b,
impl Product<usize> for usize
[src]
pub fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>>ⓘ where
S: Stream<Item = usize> + 'a,
[src]
S: Stream<Item = usize> + 'a,
impl<'a> Product<&'a usize> for usize
[src]
pub fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>>ⓘ where
S: Stream<Item = &'a usize> + 'b,
[src]
S: Stream<Item = &'a usize> + 'b,
impl Product<Wrapping<i8>> for Wrapping<i8>
[src]
pub fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>>ⓘ where
S: Stream<Item = Wrapping<i8>> + 'a,
[src]
S: Stream<Item = Wrapping<i8>> + 'a,
impl<'a> Product<&'a Wrapping<i8>> for Wrapping<i8>
[src]
pub fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>>ⓘ where
S: Stream<Item = &'a Wrapping<i8>> + 'b,
[src]
S: Stream<Item = &'a Wrapping<i8>> + 'b,
impl Product<Wrapping<i16>> for Wrapping<i16>
[src]
pub fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>>ⓘ where
S: Stream<Item = Wrapping<i16>> + 'a,
[src]
S: Stream<Item = Wrapping<i16>> + 'a,
impl<'a> Product<&'a Wrapping<i16>> for Wrapping<i16>
[src]
pub fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>>ⓘ where
S: Stream<Item = &'a Wrapping<i16>> + 'b,
[src]
S: Stream<Item = &'a Wrapping<i16>> + 'b,
impl Product<Wrapping<i32>> for Wrapping<i32>
[src]
pub fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>>ⓘ where
S: Stream<Item = Wrapping<i32>> + 'a,
[src]
S: Stream<Item = Wrapping<i32>> + 'a,
impl<'a> Product<&'a Wrapping<i32>> for Wrapping<i32>
[src]
pub fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>>ⓘ where
S: Stream<Item = &'a Wrapping<i32>> + 'b,
[src]
S: Stream<Item = &'a Wrapping<i32>> + 'b,
impl Product<Wrapping<i64>> for Wrapping<i64>
[src]
pub fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>>ⓘ where
S: Stream<Item = Wrapping<i64>> + 'a,
[src]
S: Stream<Item = Wrapping<i64>> + 'a,
impl<'a> Product<&'a Wrapping<i64>> for Wrapping<i64>
[src]
pub fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>>ⓘ where
S: Stream<Item = &'a Wrapping<i64>> + 'b,
[src]
S: Stream<Item = &'a Wrapping<i64>> + 'b,
impl Product<Wrapping<i128>> for Wrapping<i128>
[src]
pub fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>>ⓘ where
S: Stream<Item = Wrapping<i128>> + 'a,
[src]
S: Stream<Item = Wrapping<i128>> + 'a,
impl<'a> Product<&'a Wrapping<i128>> for Wrapping<i128>
[src]
pub fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>>ⓘ where
S: Stream<Item = &'a Wrapping<i128>> + 'b,
[src]
S: Stream<Item = &'a Wrapping<i128>> + 'b,
impl Product<Wrapping<isize>> for Wrapping<isize>
[src]
pub fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>>ⓘ where
S: Stream<Item = Wrapping<isize>> + 'a,
[src]
S: Stream<Item = Wrapping<isize>> + 'a,
impl<'a> Product<&'a Wrapping<isize>> for Wrapping<isize>
[src]
pub fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>>ⓘ where
S: Stream<Item = &'a Wrapping<isize>> + 'b,
[src]
S: Stream<Item = &'a Wrapping<isize>> + 'b,
impl Product<Wrapping<u8>> for Wrapping<u8>
[src]
pub fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>>ⓘ where
S: Stream<Item = Wrapping<u8>> + 'a,
[src]
S: Stream<Item = Wrapping<u8>> + 'a,
impl<'a> Product<&'a Wrapping<u8>> for Wrapping<u8>
[src]
pub fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>>ⓘ where
S: Stream<Item = &'a Wrapping<u8>> + 'b,
[src]
S: Stream<Item = &'a Wrapping<u8>> + 'b,
impl Product<Wrapping<u16>> for Wrapping<u16>
[src]
pub fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>>ⓘ where
S: Stream<Item = Wrapping<u16>> + 'a,
[src]
S: Stream<Item = Wrapping<u16>> + 'a,
impl<'a> Product<&'a Wrapping<u16>> for Wrapping<u16>
[src]
pub fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>>ⓘ where
S: Stream<Item = &'a Wrapping<u16>> + 'b,
[src]
S: Stream<Item = &'a Wrapping<u16>> + 'b,
impl Product<Wrapping<u32>> for Wrapping<u32>
[src]
pub fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>>ⓘ where
S: Stream<Item = Wrapping<u32>> + 'a,
[src]
S: Stream<Item = Wrapping<u32>> + 'a,
impl<'a> Product<&'a Wrapping<u32>> for Wrapping<u32>
[src]
pub fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>>ⓘ where
S: Stream<Item = &'a Wrapping<u32>> + 'b,
[src]
S: Stream<Item = &'a Wrapping<u32>> + 'b,
impl Product<Wrapping<u64>> for Wrapping<u64>
[src]
pub fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>>ⓘ where
S: Stream<Item = Wrapping<u64>> + 'a,
[src]
S: Stream<Item = Wrapping<u64>> + 'a,
impl<'a> Product<&'a Wrapping<u64>> for Wrapping<u64>
[src]
pub fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>>ⓘ where
S: Stream<Item = &'a Wrapping<u64>> + 'b,
[src]
S: Stream<Item = &'a Wrapping<u64>> + 'b,
impl Product<Wrapping<u128>> for Wrapping<u128>
[src]
pub fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>>ⓘ where
S: Stream<Item = Wrapping<u128>> + 'a,
[src]
S: Stream<Item = Wrapping<u128>> + 'a,
impl<'a> Product<&'a Wrapping<u128>> for Wrapping<u128>
[src]
pub fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>>ⓘ where
S: Stream<Item = &'a Wrapping<u128>> + 'b,
[src]
S: Stream<Item = &'a Wrapping<u128>> + 'b,
impl Product<Wrapping<usize>> for Wrapping<usize>
[src]
pub fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>>ⓘ where
S: Stream<Item = Wrapping<usize>> + 'a,
[src]
S: Stream<Item = Wrapping<usize>> + 'a,
impl<'a> Product<&'a Wrapping<usize>> for Wrapping<usize>
[src]
pub fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>>ⓘ where
S: Stream<Item = &'a Wrapping<usize>> + 'b,
[src]
S: Stream<Item = &'a Wrapping<usize>> + 'b,
impl Product<f32> for f32
[src]
pub fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>>ⓘ where
S: Stream<Item = f32> + 'a,
[src]
S: Stream<Item = f32> + 'a,
impl<'a> Product<&'a f32> for f32
[src]
pub fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>>ⓘ where
S: Stream<Item = &'a f32> + 'b,
[src]
S: Stream<Item = &'a f32> + 'b,
impl Product<f64> for f64
[src]
pub fn product<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a>>ⓘ where
S: Stream<Item = f64> + 'a,
[src]
S: Stream<Item = f64> + 'a,
impl<'a> Product<&'a f64> for f64
[src]
pub fn product<'b, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'b>>ⓘ where
S: Stream<Item = &'a f64> + 'b,
[src]
S: Stream<Item = &'a f64> + 'b,
impl<T, U, E> Product<Result<U, E>> for Result<T, E> where
T: Product<U>,
[src]
T: Product<U>,
pub fn product<'a, S>(
stream: S
) -> Pin<Box<dyn Future<Output = Result<T, E>> + 'a>>ⓘ where
S: Stream<Item = Result<U, E>> + 'a,
[src]
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>,
[src]
T: Product<U>,
pub fn product<'a, S>(
stream: S
) -> Pin<Box<dyn Future<Output = Option<T>> + 'a>>ⓘ where
S: Stream<Item = Option<U>> + 'a,
[src]
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));