Struct amadeus::par_sink::ExtendReducerAsync [−][src]
pub struct ExtendReducerAsync<Item, T = Item>(_, _);
Trait Implementations
impl<Item, T, B> Sink<Item> for ExtendReducerAsync<Item, T> where
T: Extend<B>,
Item: IntoIterator<Item = B>,
[src]
impl<Item, T, B> Sink<Item> for ExtendReducerAsync<Item, T> where
T: Extend<B>,
Item: IntoIterator<Item = B>,
[src]type Done = T
pub fn poll_forward(
self: Pin<&mut ExtendReducerAsync<Item, T>>,
cx: &mut Context<'_>,
stream: Pin<&mut impl Stream<Item = Item>>
) -> Poll<<ExtendReducerAsync<Item, T> as Sink<Item>>::Done>
[src]
pub fn poll_forward(
self: Pin<&mut ExtendReducerAsync<Item, T>>,
cx: &mut Context<'_>,
stream: Pin<&mut impl Stream<Item = Item>>
) -> Poll<<ExtendReducerAsync<Item, T> as Sink<Item>>::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> where
Self: Unpin,
[src]
Self: Unpin,
fn send_all<S>(&'a mut self, items: &'a mut S) -> SendAll<'a, Self, S> where
Self: Unpin,
S: Stream<Item = Item> + Unpin + ?Sized,
[src]
Self: Unpin,
S: Stream<Item = Item> + Unpin + ?Sized,
fn done(&mut self) -> Done<'_, Self, Item> where
Self: Unpin,
[src]
Self: Unpin,
impl<'pin, Item, T> Unpin for ExtendReducerAsync<Item, T> where
__ExtendReducerAsync<'pin, Item, T>: Unpin,
[src]
__ExtendReducerAsync<'pin, Item, T>: Unpin,
impl<Item, T> UnsafeUnpin for ExtendReducerAsync<Item, T>
[src]
Auto Trait Implementations
impl<Item, T> RefUnwindSafe for ExtendReducerAsync<Item, T> where
T: RefUnwindSafe,
T: RefUnwindSafe,
impl<Item, T> Send for ExtendReducerAsync<Item, T> where
T: Send,
T: Send,
impl<Item, T> Sync for ExtendReducerAsync<Item, T> where
T: Sync,
T: Sync,
impl<Item, T> UnwindSafe for ExtendReducerAsync<Item, T> where
T: UnwindSafe,
T: UnwindSafe,
Blanket Implementations
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]pub fn borrow_mut(&mut self) -> &mut T
[src]
pub fn borrow_mut(&mut self) -> &mut T
[src]Mutably borrows from an owned value. Read more
impl<A, B> Downcast<A> for B where
A: DowncastFrom<B>,
[src]
impl<A, B> Downcast<A> for B where
A: DowncastFrom<B>,
[src]pub fn downcast(self) -> Result<A, DowncastError>
[src]
impl<T> Instrument for T
[src]
impl<T> Instrument for T
[src]fn instrument(self, span: Span) -> Instrumented<Self>
[src]
fn instrument(self, span: Span) -> Instrumented<Self>
[src]Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
fn in_current_span(self) -> Instrumented<Self>
[src]
fn in_current_span(self) -> Instrumented<Self>
[src]impl<T> Instrument for T
[src]
impl<T> Instrument for T
[src]fn instrument(self, span: Span) -> Instrumented<Self>
[src]
fn instrument(self, span: Span) -> Instrumented<Self>
[src]Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
fn in_current_span(self) -> Instrumented<Self>
[src]
fn in_current_span(self) -> Instrumented<Self>
[src]impl<T> Same<T> for T
impl<T> Same<T> for T
type Output = T
type Output = T
Should always be Self
impl<T> Type for T where
T: ?Sized,
[src]
impl<T> Type for T where
T: ?Sized,
[src]pub default fn meta(self: *const T) -> <T as Type>::Meta
[src]
pub default fn meta(self: *const T) -> <T as Type>::Meta
[src]Retrieve TraitObject
, Slice
or Concrete
meta data respectively for a type
pub default fn dangling(t: <T as Type>::Meta) -> NonNull<T>
[src]
pub default fn dangling(t: <T as Type>::Meta) -> NonNull<T>
[src]Create a dangling non-null *const Self
with the provided Self::Meta
.
pub default fn fatten(thin: *mut (), t: <T as Type>::Meta) -> *mut T
[src]
pub default fn fatten(thin: *mut (), t: <T as Type>::Meta) -> *mut T
[src]Create a *mut Self
with the provided Self::Meta
.
type Meta: 'static
type Meta: 'static
Type of metadata for type.
fn meta_type(self: *const Self) -> MetaType
[src]
fn meta_type(self: *const Self) -> MetaType
[src]Helper method describing whether a type is TraitObject
, Slice
or Concrete
.
impl<T> Type for T
[src]
impl<T> Type for T
[src]pub fn meta(self: *const T) -> <T as Type>::Meta
[src]
pub fn meta(self: *const T) -> <T as Type>::Meta
[src]Retrieve TraitObject
, Slice
or Concrete
meta data respectively for a type
pub fn dangling(_t: <T as Type>::Meta) -> NonNull<T>
[src]
pub fn dangling(_t: <T as Type>::Meta) -> NonNull<T>
[src]Create a dangling non-null *const Self
with the provided Self::Meta
.
pub fn fatten(thin: *mut (), _t: <T as Type>::Meta) -> *mut T
[src]
pub fn fatten(thin: *mut (), _t: <T as Type>::Meta) -> *mut T
[src]Create a *mut Self
with the provided Self::Meta
.
fn meta_type(self: *const Self) -> MetaType
[src]
fn meta_type(self: *const Self) -> MetaType
[src]Helper method describing whether a type is TraitObject
, Slice
or Concrete
.
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,