Struct amadeus::par_sink::ReduceC7Async [−][src]
pub struct ReduceC7Async<A, B, C, D, E, F, G, S0, S1, S2, S3, S4, S5, S6> where
C: Sink<S2>,
D: Sink<S3>,
F: Sink<S5>,
E: Sink<S4>,
A: Sink<S0>,
B: Sink<S1>,
G: Sink<S6>, { /* fields omitted */ }
Trait Implementations
impl<A, B, C, D, E, F, G, S0, S1, S2, S3, S4, S5, S6> Sink<(S0, S1, S2, S3, S4, S5, S6)> for ReduceC7Async<A, B, C, D, E, F, G, S0, S1, S2, S3, S4, S5, S6> where
C: Sink<S2>,
D: Sink<S3>,
F: Sink<S5>,
E: Sink<S4>,
A: Sink<S0>,
B: Sink<S1>,
G: Sink<S6>,
[src]
impl<A, B, C, D, E, F, G, S0, S1, S2, S3, S4, S5, S6> Sink<(S0, S1, S2, S3, S4, S5, S6)> for ReduceC7Async<A, B, C, D, E, F, G, S0, S1, S2, S3, S4, S5, S6> where
C: Sink<S2>,
D: Sink<S3>,
F: Sink<S5>,
E: Sink<S4>,
A: Sink<S0>,
B: Sink<S1>,
G: Sink<S6>,
[src]type Done = (<A as Sink<S0>>::Done, <B as Sink<S1>>::Done, <C as Sink<S2>>::Done, <D as Sink<S3>>::Done, <E as Sink<S4>>::Done, <F as Sink<S5>>::Done, <G as Sink<S6>>::Done)
pub fn poll_forward(
self: Pin<&mut ReduceC7Async<A, B, C, D, E, F, G, S0, S1, S2, S3, S4, S5, S6>>,
cx: &mut Context<'_>,
stream: Pin<&mut impl Stream<Item = (S0, S1, S2, S3, S4, S5, S6)>>
) -> Poll<<ReduceC7Async<A, B, C, D, E, F, G, S0, S1, S2, S3, S4, S5, S6> as Sink<(S0, S1, S2, S3, S4, S5, S6)>>::Done>
[src]
pub fn poll_forward(
self: Pin<&mut ReduceC7Async<A, B, C, D, E, F, G, S0, S1, S2, S3, S4, S5, S6>>,
cx: &mut Context<'_>,
stream: Pin<&mut impl Stream<Item = (S0, S1, S2, S3, S4, S5, S6)>>
) -> Poll<<ReduceC7Async<A, B, C, D, E, F, G, S0, S1, S2, S3, S4, S5, S6> as Sink<(S0, S1, S2, S3, S4, S5, S6)>>::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, A, B, C, D, E, F, G, S0, S1, S2, S3, S4, S5, S6> Unpin for ReduceC7Async<A, B, C, D, E, F, G, S0, S1, S2, S3, S4, S5, S6> where
C: Sink<S2>,
D: Sink<S3>,
F: Sink<S5>,
E: Sink<S4>,
A: Sink<S0>,
B: Sink<S1>,
G: Sink<S6>,
__ReduceC7Async<'pin, A, B, C, D, E, F, G, S0, S1, S2, S3, S4, S5, S6>: Unpin,
[src]
C: Sink<S2>,
D: Sink<S3>,
F: Sink<S5>,
E: Sink<S4>,
A: Sink<S0>,
B: Sink<S1>,
G: Sink<S6>,
__ReduceC7Async<'pin, A, B, C, D, E, F, G, S0, S1, S2, S3, S4, S5, S6>: Unpin,
impl<A, B, C, D, E, F, G, S0, S1, S2, S3, S4, S5, S6> UnsafeUnpin for ReduceC7Async<A, B, C, D, E, F, G, S0, S1, S2, S3, S4, S5, S6> where
C: Sink<S2>,
D: Sink<S3>,
F: Sink<S5>,
E: Sink<S4>,
A: Sink<S0>,
B: Sink<S1>,
G: Sink<S6>,
[src]
C: Sink<S2>,
D: Sink<S3>,
F: Sink<S5>,
E: Sink<S4>,
A: Sink<S0>,
B: Sink<S1>,
G: Sink<S6>,
Auto Trait Implementations
impl<A, B, C, D, E, F, G, S0, S1, S2, S3, S4, S5, S6> RefUnwindSafe for ReduceC7Async<A, B, C, D, E, F, G, S0, S1, S2, S3, S4, S5, S6> where
A: RefUnwindSafe,
B: RefUnwindSafe,
C: RefUnwindSafe,
D: RefUnwindSafe,
E: RefUnwindSafe,
F: RefUnwindSafe,
G: RefUnwindSafe,
S0: RefUnwindSafe,
S1: RefUnwindSafe,
S2: RefUnwindSafe,
S3: RefUnwindSafe,
S4: RefUnwindSafe,
S5: RefUnwindSafe,
S6: RefUnwindSafe,
<A as Sink<S0>>::Done: RefUnwindSafe,
<B as Sink<S1>>::Done: RefUnwindSafe,
<C as Sink<S2>>::Done: RefUnwindSafe,
<D as Sink<S3>>::Done: RefUnwindSafe,
<E as Sink<S4>>::Done: RefUnwindSafe,
<F as Sink<S5>>::Done: RefUnwindSafe,
<G as Sink<S6>>::Done: RefUnwindSafe,
A: RefUnwindSafe,
B: RefUnwindSafe,
C: RefUnwindSafe,
D: RefUnwindSafe,
E: RefUnwindSafe,
F: RefUnwindSafe,
G: RefUnwindSafe,
S0: RefUnwindSafe,
S1: RefUnwindSafe,
S2: RefUnwindSafe,
S3: RefUnwindSafe,
S4: RefUnwindSafe,
S5: RefUnwindSafe,
S6: RefUnwindSafe,
<A as Sink<S0>>::Done: RefUnwindSafe,
<B as Sink<S1>>::Done: RefUnwindSafe,
<C as Sink<S2>>::Done: RefUnwindSafe,
<D as Sink<S3>>::Done: RefUnwindSafe,
<E as Sink<S4>>::Done: RefUnwindSafe,
<F as Sink<S5>>::Done: RefUnwindSafe,
<G as Sink<S6>>::Done: RefUnwindSafe,
impl<A, B, C, D, E, F, G, S0, S1, S2, S3, S4, S5, S6> Send for ReduceC7Async<A, B, C, D, E, F, G, S0, S1, S2, S3, S4, S5, S6> where
A: Send,
B: Send,
C: Send,
D: Send,
E: Send,
F: Send,
G: Send,
S0: Send,
S1: Send,
S2: Send,
S3: Send,
S4: Send,
S5: Send,
S6: Send,
<A as Sink<S0>>::Done: Send,
<B as Sink<S1>>::Done: Send,
<C as Sink<S2>>::Done: Send,
<D as Sink<S3>>::Done: Send,
<E as Sink<S4>>::Done: Send,
<F as Sink<S5>>::Done: Send,
<G as Sink<S6>>::Done: Send,
A: Send,
B: Send,
C: Send,
D: Send,
E: Send,
F: Send,
G: Send,
S0: Send,
S1: Send,
S2: Send,
S3: Send,
S4: Send,
S5: Send,
S6: Send,
<A as Sink<S0>>::Done: Send,
<B as Sink<S1>>::Done: Send,
<C as Sink<S2>>::Done: Send,
<D as Sink<S3>>::Done: Send,
<E as Sink<S4>>::Done: Send,
<F as Sink<S5>>::Done: Send,
<G as Sink<S6>>::Done: Send,
impl<A, B, C, D, E, F, G, S0, S1, S2, S3, S4, S5, S6> Sync for ReduceC7Async<A, B, C, D, E, F, G, S0, S1, S2, S3, S4, S5, S6> where
A: Sync,
B: Sync,
C: Sync,
D: Sync,
E: Sync,
F: Sync,
G: Sync,
S0: Sync,
S1: Sync,
S2: Sync,
S3: Sync,
S4: Sync,
S5: Sync,
S6: Sync,
<A as Sink<S0>>::Done: Sync,
<B as Sink<S1>>::Done: Sync,
<C as Sink<S2>>::Done: Sync,
<D as Sink<S3>>::Done: Sync,
<E as Sink<S4>>::Done: Sync,
<F as Sink<S5>>::Done: Sync,
<G as Sink<S6>>::Done: Sync,
A: Sync,
B: Sync,
C: Sync,
D: Sync,
E: Sync,
F: Sync,
G: Sync,
S0: Sync,
S1: Sync,
S2: Sync,
S3: Sync,
S4: Sync,
S5: Sync,
S6: Sync,
<A as Sink<S0>>::Done: Sync,
<B as Sink<S1>>::Done: Sync,
<C as Sink<S2>>::Done: Sync,
<D as Sink<S3>>::Done: Sync,
<E as Sink<S4>>::Done: Sync,
<F as Sink<S5>>::Done: Sync,
<G as Sink<S6>>::Done: Sync,
impl<A, B, C, D, E, F, G, S0, S1, S2, S3, S4, S5, S6> UnwindSafe for ReduceC7Async<A, B, C, D, E, F, G, S0, S1, S2, S3, S4, S5, S6> where
A: UnwindSafe,
B: UnwindSafe,
C: UnwindSafe,
D: UnwindSafe,
E: UnwindSafe,
F: UnwindSafe,
G: UnwindSafe,
S0: UnwindSafe,
S1: UnwindSafe,
S2: UnwindSafe,
S3: UnwindSafe,
S4: UnwindSafe,
S5: UnwindSafe,
S6: UnwindSafe,
<A as Sink<S0>>::Done: UnwindSafe,
<B as Sink<S1>>::Done: UnwindSafe,
<C as Sink<S2>>::Done: UnwindSafe,
<D as Sink<S3>>::Done: UnwindSafe,
<E as Sink<S4>>::Done: UnwindSafe,
<F as Sink<S5>>::Done: UnwindSafe,
<G as Sink<S6>>::Done: UnwindSafe,
A: UnwindSafe,
B: UnwindSafe,
C: UnwindSafe,
D: UnwindSafe,
E: UnwindSafe,
F: UnwindSafe,
G: UnwindSafe,
S0: UnwindSafe,
S1: UnwindSafe,
S2: UnwindSafe,
S3: UnwindSafe,
S4: UnwindSafe,
S5: UnwindSafe,
S6: UnwindSafe,
<A as Sink<S0>>::Done: UnwindSafe,
<B as Sink<S1>>::Done: UnwindSafe,
<C as Sink<S2>>::Done: UnwindSafe,
<D as Sink<S3>>::Done: UnwindSafe,
<E as Sink<S4>>::Done: UnwindSafe,
<F as Sink<S5>>::Done: UnwindSafe,
<G as Sink<S6>>::Done: 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>,