Struct parallel_stream::FromStream [−][src]
pub struct FromStream<S> { /* fields omitted */ }
Expand description
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: Stream + Send + Sync + Unpin + 'static> ParallelStream for FromStream<S> where
S::Item: Send,
impl<S: Stream + Send + Sync + Unpin + 'static> ParallelStream for FromStream<S> where
S::Item: Send,
type Item = S::Item
type Item = S::Item
The type of items yielded by this stream.
Attempts to receive the next item from the stream.
Applies f
to each item of this stream in parallel, producing a new
stream with the results. Read more
Applies f
to each item of this stream in parallel, producing a new
stream with the results. Read more
Creates a stream that yields its first n
elements.
Applies f
to each item of this stream in parallel.
Auto Trait Implementations
impl<S> RefUnwindSafe for FromStream<S> where
S: RefUnwindSafe,
impl<S> Send for FromStream<S> where
S: Send,
impl<S> Sync for FromStream<S> where
S: Sync,
impl<S> UnwindSafe for FromStream<S> where
S: UnwindSafe,
Blanket Implementations
Mutably borrows from an owned value. Read more