Struct AllReducerAsync 

pub struct AllReducerAsync<Item, F>(/* private fields */);

Trait Implementations

impl<'de, Item, F> Deserialize<'de> for AllReducerAsync<Item, F>

where F: Deserialize<'de>,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<Item, F> Serialize for AllReducerAsync<Item, F>

where F: Serialize,

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<Item, F> Sink<Item> for AllReducerAsync<Item, F>

where F: FnMut<(Item,), Output = bool>,

type Done = bool

fn poll_forward( self: Pin<&mut Self>, cx: &mut Context<'_>, stream: Pin<&mut impl Stream<Item = Item>>, ) -> 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).

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, Item, F> Unpin for AllReducerAsync<Item, F>

where __AllReducerAsync<'pin, Item, F>: Unpin,

impl<Item, F> UnsafeUnpin for AllReducerAsync<Item, F>