pub struct IntoConcurrentStream<T>(/* private fields */);
Expand description
Concurrent async iterator that moves out of a vector.
Trait Implementations§
source§impl<T> ConcurrentStream for IntoConcurrentStream<T>
impl<T> ConcurrentStream for IntoConcurrentStream<T>
source§async fn drive<C>(self, consumer: C) -> C::Output
async fn drive<C>(self, consumer: C) -> C::Output
Internal method used to define the behavior of this concurrent iterator.
You should not need to call this directly. This method causes the
iterator self to start producing items and to feed them to the consumer
consumer one by one.
source§fn concurrency_limit(&self) -> Option<NonZeroUsize>
fn concurrency_limit(&self) -> Option<NonZeroUsize>
How much concurrency should we apply?
source§fn size_hint(&self) -> (usize, Option<usize>)
fn size_hint(&self) -> (usize, Option<usize>)
How many items could we potentially end up returning?
source§fn enumerate(self) -> Enumerate<Self>where
Self: Sized,
fn enumerate(self) -> Enumerate<Self>where
Self: Sized,
Creates a stream which gives the current iteration count as well as
the next value. Read more
source§fn limit(self, limit: Option<NonZeroUsize>) -> Limit<Self>where
Self: Sized,
fn limit(self, limit: Option<NonZeroUsize>) -> Limit<Self>where
Self: Sized,
Obtain a simple pass-through adapter.
source§fn take(self, limit: usize) -> Take<Self>where
Self: Sized,
fn take(self, limit: usize) -> Take<Self>where
Self: Sized,
Creates a stream that yields the first
n
elements, or fewer if the
underlying iterator ends sooner.source§fn map<F, FutB, B>(
self,
f: F,
) -> Map<Self, F, Self::Future, Self::Item, FutB, B>
fn map<F, FutB, B>( self, f: F, ) -> Map<Self, F, Self::Future, Self::Item, FutB, B>
Convert items from one type into another
Auto Trait Implementations§
impl<T> Freeze for IntoConcurrentStream<T>
impl<T> RefUnwindSafe for IntoConcurrentStream<T>where
T: RefUnwindSafe,
impl<T> Send for IntoConcurrentStream<T>where
T: Send,
impl<T> Sync for IntoConcurrentStream<T>where
T: Sync,
impl<T> Unpin for IntoConcurrentStream<T>
impl<T> UnwindSafe for IntoConcurrentStream<T>where
T: RefUnwindSafe + UnwindSafe,
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<S> IntoConcurrentStream for Swhere
S: ConcurrentStream,
impl<S> IntoConcurrentStream for Swhere
S: ConcurrentStream,
source§type Item = <S as ConcurrentStream>::Item
type Item = <S as ConcurrentStream>::Item
The type of the elements being iterated over.
source§type IntoConcurrentStream = S
type IntoConcurrentStream = S
Which kind of iterator are we turning this into?
source§fn into_co_stream(self) -> <S as IntoConcurrentStream>::IntoConcurrentStream
fn into_co_stream(self) -> <S as IntoConcurrentStream>::IntoConcurrentStream
Convert
self
into a concurrent iterator.