Struct BoolOrReducerAsync 

pub struct BoolOrReducerAsync(/* private fields */);

Trait Implementations

impl<'de> Deserialize<'de> for BoolOrReducerAsync

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for BoolOrReducerAsync

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Sink<bool> for BoolOrReducerAsync

type Done = bool

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

where __BoolOrReducerAsync<'pin>: Unpin,

impl UnsafeUnpin for BoolOrReducerAsync