Struct amadeus::par_sink::ForEachReducer [−][src]
pub struct ForEachReducer<Item, F>(_, _);
Trait Implementations
impl<Item, F> Clone for ForEachReducer<Item, F> where
F: Clone,
[src]
impl<Item, F> Clone for ForEachReducer<Item, F> where
F: Clone,
[src]pub fn clone(&self) -> ForEachReducer<Item, F>
[src]
pub fn clone(&self) -> ForEachReducer<Item, F>
[src]Returns a copy of the value. Read more
pub fn clone_from(&mut self, _source: &ForEachReducer<Item, F>)
[src]
pub fn clone_from(&mut self, _source: &ForEachReducer<Item, F>)
[src]Performs copy-assignment from source
. Read more
impl<'de, Item, F> Deserialize<'de> for ForEachReducer<Item, F> where
F: Deserialize<'de>,
[src]
impl<'de, Item, F> Deserialize<'de> for ForEachReducer<Item, F> where
F: Deserialize<'de>,
[src]pub fn deserialize<__D>(
__deserializer: __D
) -> Result<ForEachReducer<Item, F>, <__D as Deserializer<'de>>::Error> where
__D: Deserializer<'de>,
[src]
pub fn deserialize<__D>(
__deserializer: __D
) -> Result<ForEachReducer<Item, F>, <__D as Deserializer<'de>>::Error> where
__D: Deserializer<'de>,
[src]Deserialize this value from the given Serde deserializer. Read more
impl<Item, F> Reducer<Item> for ForEachReducer<Item, F> where
F: FnMut<(Item,), Output = ()>,
[src]
impl<Item, F> Reducer<Item> for ForEachReducer<Item, F> where
F: FnMut<(Item,), Output = ()>,
[src]type Done = ()
type Async = ForEachReducer<Item, F>
pub fn into_async(self) -> <ForEachReducer<Item, F> as Reducer<Item>>::Async
[src]
impl<Item, F> ReducerProcessSend<Item> for ForEachReducer<Item, F> where
F: FnMut<(Item,), Output = ()>,
[src]
impl<Item, F> ReducerProcessSend<Item> for ForEachReducer<Item, F> where
F: FnMut<(Item,), Output = ()>,
[src]impl<Item, F> ReducerSend<Item> for ForEachReducer<Item, F> where
F: FnMut<(Item,), Output = ()>,
[src]
impl<Item, F> ReducerSend<Item> for ForEachReducer<Item, F> where
F: FnMut<(Item,), Output = ()>,
[src]impl<Item, F> Serialize for ForEachReducer<Item, F> where
F: Serialize,
[src]
impl<Item, F> Serialize for ForEachReducer<Item, F> where
F: Serialize,
[src]pub fn serialize<__S>(
&self,
__serializer: __S
) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error> where
__S: Serializer,
[src]
pub fn serialize<__S>(
&self,
__serializer: __S
) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error> where
__S: Serializer,
[src]Serialize this value into the given Serde serializer. Read more
impl<Item, F> Sink<Item> for ForEachReducer<Item, F> where
F: FnMut<(Item,), Output = ()>,
[src]
impl<Item, F> Sink<Item> for ForEachReducer<Item, F> where
F: FnMut<(Item,), Output = ()>,
[src]type Done = ()
pub fn poll_forward(
self: Pin<&mut ForEachReducer<Item, F>>,
cx: &mut Context<'_>,
stream: Pin<&mut impl Stream<Item = Item>>
) -> Poll<<ForEachReducer<Item, F> as Sink<Item>>::Done>
[src]
pub fn poll_forward(
self: Pin<&mut ForEachReducer<Item, F>>,
cx: &mut Context<'_>,
stream: Pin<&mut impl Stream<Item = Item>>
) -> Poll<<ForEachReducer<Item, F> 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, F> Unpin for ForEachReducer<Item, F> where
__ForEachReducer<'pin, Item, F>: Unpin,
[src]
__ForEachReducer<'pin, Item, F>: Unpin,
impl<Item, F> UnsafeUnpin for ForEachReducer<Item, F>
[src]
Auto Trait Implementations
impl<Item, F> RefUnwindSafe for ForEachReducer<Item, F> where
F: RefUnwindSafe,
F: RefUnwindSafe,
impl<Item, F> Send for ForEachReducer<Item, F> where
F: Send,
F: Send,
impl<Item, F> Sync for ForEachReducer<Item, F> where
F: Sync,
F: Sync,
impl<Item, F> UnwindSafe for ForEachReducer<Item, F> where
F: UnwindSafe,
F: UnwindSafe,
Blanket Implementations
impl<T> Any for T where
T: Any + Serialize + Deserialize,
[src]
impl<T> Any for T where
T: Any + Serialize + Deserialize,
[src]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> Serialize for T where
T: Serialize + ?Sized,
[src]
impl<T> Serialize for T where
T: Serialize + ?Sized,
[src]pub fn erased_serialize(
&self,
serializer: &mut dyn Serializer
) -> Result<Ok, Error>
[src]
&self,
serializer: &mut dyn Serializer
) -> Result<Ok, Error>
impl<T> ToOwned for T where
T: Clone,
[src]
impl<T> ToOwned for T where
T: Clone,
[src]type Owned = T
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T
[src]
pub fn to_owned(&self) -> T
[src]Creates owned data from borrowed data, usually by cloning. Read more
pub fn clone_into(&self, target: &mut T)
[src]
pub fn clone_into(&self, target: &mut T)
[src]🔬 This is a nightly-only experimental API. (toowned_clone_into
)
recently added
Uses borrowed data to replace owned data, usually by cloning. Read more
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>,
pub fn vzip(self) -> V
impl<T> Deserialize for T where
T: DeserializeOwned,
[src]
T: DeserializeOwned,
impl<T> DeserializeOwned for T where
T: for<'de> Deserialize<'de>,
[src]
T: for<'de> Deserialize<'de>,
impl<T> ProcessSend for T where
T: Send + Serialize + for<'de> Deserialize<'de> + ?Sized,
[src]
T: Send + Serialize + for<'de> Deserialize<'de> + ?Sized,
impl<T> Serialize for T where
T: Serialize + ?Sized,
[src]
T: Serialize + ?Sized,