Struct ReduceC2Async

Source

pub struct ReduceC2Async<A, B, S0, S1>where
    A: Sink<S0>,
    B: Sink<S1>,
{ /* private fields */ }

Trait Implementations§

Source §

impl<A: Sink<S0>, B: Sink<S1>, S0, S1> Sink<(S0, S1)> for ReduceC2Async<A, B, S0, S1>

Source §

type Done = (<A as Sink<S0>>::Done, >::Done)

Source §

fn poll_forward( self: Pin<&mut Self>, cx: &mut Context<'_>, stream: Pin<&mut impl Stream<Item = (S0, S1)>>, ) -> Poll<Self::Done>

Returns Poll::Ready when a) it can’t accept any more elements from stream and b) all accepted elements have been fully processed. By convention, stream yielding None typically triggers (a).

Source §

fn send(&mut self, item: Item) -> Send<'_, Self, Item> ⓘ
where Self: Unpin,

Source §

fn send_all<'a, S>(&'a mut self, items: &'a mut S) -> SendAll<'a, Self, S> ⓘ
where S: Stream<Item = Item> + Unpin + ?Sized, Self: Unpin,

Source §

fn done(&mut self) -> Done<'_, Self, Item> ⓘ
where Self: Unpin,

Source §

impl<'pin, A, B, S0, S1> Unpin for ReduceC2Async<A, B, S0, S1>
where A: Sink<S0>, B: Sink<S1>, __ReduceC2Async<'pin, A, B, S0, S1>: Unpin,

Source §

impl<A, B, S0, S1> UnsafeUnpin for ReduceC2Async<A, B, S0, S1>
where A: Sink<S0>, B: Sink<S1>,

Auto Trait Implementations§

§

impl<A, B, S0, S1> Freeze for ReduceC2Async<A, B, S0, S1>
where A: Freeze, B: Freeze, <A as Sink<S0>>::Done: Freeze, >::Done: Freeze, S0: Freeze, S1: Freeze,

§

impl<A, B, S0, S1> RefUnwindSafe for ReduceC2Async<A, B, S0, S1>
where A: RefUnwindSafe, B: RefUnwindSafe, <A as Sink<S0>>::Done: RefUnwindSafe, >::Done: RefUnwindSafe, S0: RefUnwindSafe, S1: RefUnwindSafe,

§

impl<A, B, S0, S1> Send for ReduceC2Async<A, B, S0, S1>
where A: Send, B: Send, <A as Sink<S0>>::Done: Send, >::Done: Send, S0: Send, S1: Send,

§

impl<A, B, S0, S1> Sync for ReduceC2Async<A, B, S0, S1>
where A: Sync, B: Sync, <A as Sink<S0>>::Done: Sync, >::Done: Sync, S0: Sync, S1: Sync,

§

impl<A, B, S0, S1> UnsafeUnpin for ReduceC2Async<A, B, S0, S1>
where A: UnsafeUnpin, B: UnsafeUnpin, <A as Sink<S0>>::Done: UnsafeUnpin, >::Done: UnsafeUnpin, S0: UnsafeUnpin, S1: UnsafeUnpin,

§

impl<A, B, S0, S1> UnwindSafe for ReduceC2Async<A, B, S0, S1>
where A: UnwindSafe, B: UnwindSafe, <A as Sink<S0>>::Done: UnwindSafe, >::Done: UnwindSafe, S0: UnwindSafe, S1: UnwindSafe,

Blanket Implementations§

Source §

impl<T> Any for T
where T: 'static + ?Sized,

Source §

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

Source §

impl<T> Borrow<T> for T
where T: ?Sized,

Source §

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

Source §

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source §

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

Source §

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

Source §

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

Source §

impl<T> From<T> for T

Source §

fn from(t: T) -> T

Returns the argument unchanged.

Source §

impl<T, U> Into for T
where U: From<T>,

Source §

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source §

impl<T> IntoEither for T

Source §

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more

Source §

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more

Source §

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

Source §

impl<T, U> TryFrom for T
where U: Into<T>,

Source §

type Error = Infallible

The type returned in the event of a conversion error.

Source §

fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>

Performs the conversion.

Source §

impl<T, U> TryInto for T
where U: TryFrom<T>,

Source §

type Error = >::Error

The type returned in the event of a conversion error.

Source §

fn try_into(self) -> Result<U, >::Error>

Performs the conversion.

Source §

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source §

ReduceC2Async

Struct ReduceC2Async Copy item path

Trait Implementations§

impl<A: Sink<S0>, B: Sink<S1>, S0, S1> Sink<(S0, S1)> for ReduceC2Async<A, B, S0, S1>

type Done = (<A as Sink<S0>>::Done, <B as Sink<S1>>::Done)

fn poll_forward( self: Pin<&mut Self>, cx: &mut Context<'_>, stream: Pin<&mut impl Stream<Item = (S0, S1)>>, ) -> Poll<Self::Done>

fn send(&mut self, item: Item) -> Send<'_, Self, Item> ⓘwhere Self: Unpin,

fn send_all<'a, S>(&'a mut self, items: &'a mut S) -> SendAll<'a, Self, S> ⓘwhere S: Stream<Item = Item> + Unpin + ?Sized, Self: Unpin,

fn done(&mut self) -> Done<'_, Self, Item> ⓘwhere Self: Unpin,

impl<'pin, A, B, S0, S1> Unpin for ReduceC2Async<A, B, S0, S1>where A: Sink<S0>, B: Sink<S1>, __ReduceC2Async<'pin, A, B, S0, S1>: Unpin,

impl<A, B, S0, S1> UnsafeUnpin for ReduceC2Async<A, B, S0, S1>where A: Sink<S0>, B: Sink<S1>,

Auto Trait Implementations§

impl<A, B, S0, S1> Freeze for ReduceC2Async<A, B, S0, S1>where A: Freeze, B: Freeze, <A as Sink<S0>>::Done: Freeze, <B as Sink<S1>>::Done: Freeze, S0: Freeze, S1: Freeze,

impl<A, B, S0, S1> RefUnwindSafe for ReduceC2Async<A, B, S0, S1>where A: RefUnwindSafe, B: RefUnwindSafe, <A as Sink<S0>>::Done: RefUnwindSafe, <B as Sink<S1>>::Done: RefUnwindSafe, S0: RefUnwindSafe, S1: RefUnwindSafe,

impl<A, B, S0, S1> Send for ReduceC2Async<A, B, S0, S1>where A: Send, B: Send, <A as Sink<S0>>::Done: Send, <B as Sink<S1>>::Done: Send, S0: Send, S1: Send,

impl<A, B, S0, S1> Sync for ReduceC2Async<A, B, S0, S1>where A: Sync, B: Sync, <A as Sink<S0>>::Done: Sync, <B as Sink<S1>>::Done: Sync, S0: Sync, S1: Sync,

impl<A, B, S0, S1> UnsafeUnpin for ReduceC2Async<A, B, S0, S1>where A: UnsafeUnpin, B: UnsafeUnpin, <A as Sink<S0>>::Done: UnsafeUnpin, <B as Sink<S1>>::Done: UnsafeUnpin, S0: UnsafeUnpin, S1: UnsafeUnpin,

impl<A, B, S0, S1> UnwindSafe for ReduceC2Async<A, B, S0, S1>where A: UnwindSafe, B: UnwindSafe, <A as Sink<S0>>::Done: UnwindSafe, <B as Sink<S1>>::Done: UnwindSafe, S0: UnwindSafe, S1: UnwindSafe,

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DTwhere ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DTwhere ST: ?Sized, DT: ?Sized,

impl<T> From<T> for T

fn from(t: T) -> T

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>where F: FnOnce(&Self) -> bool,

impl<T> Read<Exclusive, BecauseExclusive> for Twhere T: ?Sized,

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

fn vzip(self) -> V

Struct ReduceC2Async

fn send(&mut self, item: Item) -> Send<'_, Self, Item> ⓘ
where Self: Unpin,

fn send_all<'a, S>(&'a mut self, items: &'a mut S) -> SendAll<'a, Self, S> ⓘ
where S: Stream<Item = Item> + Unpin + ?Sized, Self: Unpin,

fn done(&mut self) -> Done<'_, Self, Item> ⓘ
where Self: Unpin,

impl<'pin, A, B, S0, S1> Unpin for ReduceC2Async<A, B, S0, S1>
where A: Sink<S0>, B: Sink<S1>, __ReduceC2Async<'pin, A, B, S0, S1>: Unpin,

impl<A, B, S0, S1> UnsafeUnpin for ReduceC2Async<A, B, S0, S1>
where A: Sink<S0>, B: Sink<S1>,

impl<A, B, S0, S1> Freeze for ReduceC2Async<A, B, S0, S1>
where A: Freeze, B: Freeze, <A as Sink<S0>>::Done: Freeze, <B as Sink<S1>>::Done: Freeze, S0: Freeze, S1: Freeze,

impl<A, B, S0, S1> RefUnwindSafe for ReduceC2Async<A, B, S0, S1>
where A: RefUnwindSafe, B: RefUnwindSafe, <A as Sink<S0>>::Done: RefUnwindSafe, <B as Sink<S1>>::Done: RefUnwindSafe, S0: RefUnwindSafe, S1: RefUnwindSafe,

impl<A, B, S0, S1> Send for ReduceC2Async<A, B, S0, S1>
where A: Send, B: Send, <A as Sink<S0>>::Done: Send, <B as Sink<S1>>::Done: Send, S0: Send, S1: Send,

impl<A, B, S0, S1> Sync for ReduceC2Async<A, B, S0, S1>
where A: Sync, B: Sync, <A as Sink<S0>>::Done: Sync, <B as Sink<S1>>::Done: Sync, S0: Sync, S1: Sync,

impl<A, B, S0, S1> UnsafeUnpin for ReduceC2Async<A, B, S0, S1>
where A: UnsafeUnpin, B: UnsafeUnpin, <A as Sink<S0>>::Done: UnsafeUnpin, <B as Sink<S1>>::Done: UnsafeUnpin, S0: UnsafeUnpin, S1: UnsafeUnpin,

impl<A, B, S0, S1> UnwindSafe for ReduceC2Async<A, B, S0, S1>
where A: UnwindSafe, B: UnwindSafe, <A as Sink<S0>>::Done: UnwindSafe, <B as Sink<S1>>::Done: UnwindSafe, S0: UnwindSafe, S1: UnwindSafe,

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,