Struct amadeus_core::par_sink::AnyReducerAsync

pub struct AnyReducerAsync<Item, F>(_, _, _);

Trait Implementations

impl<'de, Item, F> Deserialize<'de> for AnyReducerAsync<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> PinnedDrop for AnyReducerAsync<Item, F>

unsafe fn drop(self: Pin<&mut Self>)

impl<Item, F> Serialize for AnyReducerAsync<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 AnyReducerAsync<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>ⓘ

Important traits for Send<'_, S, Item>

impl<S: ?Sized + Sink<Item> + Unpin, Item, '_> Future for Send<'_, S, Item> type Output = Option<S::Done>;

where
    Self: Unpin, 

fn send_all<'a, S: ?Sized>(
    &'a mut self,
    items: &'a mut S
) -> SendAll<'a, Self, S>ⓘ

Important traits for SendAll<'_, S, St>

impl<S: ?Sized + Sink<Item> + Unpin, St: ?Sized + Stream<Item = Item> + Unpin, Item, '_> Future for SendAll<'_, S, St> type Output = Option<S::Done>;

where
    S: Stream<Item = Item> + Unpin,
    Self: Unpin, 

fn done(&mut self) -> Done<Self, Item>ⓘ

Important traits for Done<'_, S, Item>

impl<S: ?Sized + Sink<Item> + Unpin, Item, '_> Future for Done<'_, S, Item> type Output = S::Done;

where
    Self: Unpin, 

impl<'pin, Item, F> Unpin for AnyReducerAsync<Item, F> where
    __AnyReducerAsync<'pin, Item, F>: Unpin, 

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