Struct parallel_stream::FromStream

pub struct FromStream<S> { /* fields omitted */ }

A parallel stream that was created from sequential stream.

This stream is created by the from_stream function. See it documentation for more.

Trait Implementations

impl<S: Clone> Clone for FromStream<S>

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<S: Debug> Debug for FromStream<S>

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

Formats the value using the given formatter.

impl<S: Stream + Send + Sync + Unpin + 'static> ParallelStream for FromStream<S> where
    S::Item: Send, 

type Item = S::Item

The type of items yielded by this stream.

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

Attempts to receive the next item from the stream.

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.

impl<'__pin, S> Unpin for FromStream<S> where
    __Origin<'__pin, S>: Unpin,