Struct Take

pub struct Take<S> { /* private fields */ }

A stream that yields the first n items of another stream.

This struct is created by the take method on ParallelStream. See its documentation for more.

Trait Implementations

impl<S: Clone> Clone for Take<S>

fn clone(&self) -> Take<S>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<S: Debug> Debug for Take<S>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<S: ParallelStream> ParallelStream for Take<S>

type Item = <S as ParallelStream>::Item

The type of items yielded by this stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<S::Item>>

Attempts to receive the next item from the stream.

fn limit(self, limit: impl Into<Option<usize>>) -> Self

Set a max concurrency limit

fn get_limit(&self) -> Option<usize>

Get the max concurrency limit

fn map<F, T, Fut>(self, f: F) -> Map<T>

where F: FnMut(Self::Item) -> Fut + Send + Sync + Copy + 'static, T: Send + 'static, Fut: Future<Output = T> + Send,

Applies f to each item of this stream in parallel, producing a new stream with the results.

fn next(&mut self) -> NextFuture<'_, Self>

Applies f to each item of this stream in parallel, producing a new stream with the results.

fn take(self, n: usize) -> Take<Self>

where Self: Sized,

Creates a stream that yields its first n elements.

fn for_each<F, Fut>(self, f: F) -> ForEach

where F: FnMut(Self::Item) -> Fut + Send + Sync + Copy + 'static, Fut: Future<Output = ()> + Send,

Applies f to each item of this stream in parallel.

fn collect<'a, B>(self) -> Pin<Box<dyn Future<Output = B> + Send + 'a>>

where Self: Sized + 'a, B: FromParallelStream<Self::Item>,

Transforms a stream into a collection.

impl<'__pin, S> Unpin for Take<S>

where PinnedFieldsOf<__Origin<'__pin, S>>: Unpin,