Struct amadeus_core::par_sink::AnyReducerAsync[−][src]

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

Trait Implementations

impl<'de, Item, F> Deserialize<'de> for AnyReducerAsync<Item, F> where
    F: Deserialize<'de>, [src]

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, [src]

Deserialize this value from the given Serde deserializer. Read more

impl<Item, F> PinnedDrop for AnyReducerAsync<Item, F>[src]

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

impl<Item, F> Serialize for AnyReducerAsync<Item, F> where
    F: Serialize, [src]

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
    __S: Serializer, [src]

Serialize this value into the given Serde serializer. Read more

impl<Item, F> Sink<Item> for AnyReducerAsync<Item, F> where
    F: FnMut<(Item,), Output = bool>, [src]

type Done = bool

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

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). Read more

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

Notable 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, [src]

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

Notable 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, [src]

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

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

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

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

impl<Item, F> UnsafeUnpin for AnyReducerAsync<Item, F>[src]

Auto Trait Implementations

impl<Item, F> RefUnwindSafe for AnyReducerAsync<Item, F> where
    F: RefUnwindSafe, 

impl<Item, F> Send for AnyReducerAsync<Item, F> where
    F: Send, 

impl<Item, F> Sync for AnyReducerAsync<Item, F> where
    F: Sync, 

impl<Item, F> UnwindSafe for AnyReducerAsync<Item, F> where
    F: UnwindSafe, 

Blanket Implementations

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

pub fn type_id(&self) -> TypeId[src]

Gets the TypeId of self. Read more

impl<T> Borrow<T> for T where
    T: ?Sized, [src]

pub fn borrow(&self) -> &T[src]

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T where
    T: ?Sized, [src]

pub fn borrow_mut(&mut self) -> &mut T[src]

Mutably borrows from an owned value. Read more

impl<T> From<T> for T[src]

pub fn from(t: T) -> T[src]

Performs the conversion.

impl<T, U> Into<U> for T where
    U: From<T>, [src]

pub fn into(self) -> U[src]

Performs the conversion.

impl<T, U> TryFrom<U> for T where
    U: Into<T>, [src]

type Error = Infallible

The type returned in the event of a conversion error.

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

Performs the conversion.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, [src]

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

The type returned in the event of a conversion error.

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

Performs the conversion.

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

pub fn vzip(self) -> V

impl<T> DeserializeOwned for T where
    T: for<'de> Deserialize<'de>, [src]

impl<T> ProcessSend for T where
    T: Send + Serialize + for<'de> Deserialize<'de> + ?Sized, [src]