[−][src]Struct futures_util::stream::Zip
An adapter for merging the output of two streams.
The merged stream produces items from one or both of the underlying streams as they become available.
Trait Implementations
impl<St1: Debug + Stream, St2: Debug + Stream> Debug for Zip<St1, St2> where
St1::Item: Debug,
St2::Item: Debug, [src]
[+]
impl<St1: Debug + Stream, St2: Debug + Stream> Debug for Zip<St1, St2> where
St1::Item: Debug,
St2::Item: Debug, impl<St1: Stream + Unpin, St2: Stream + Unpin> Unpin for Zip<St1, St2>[src]
impl<St1: Stream + Unpin, St2: Stream + Unpin> Unpin for Zip<St1, St2>impl<St1, St2> Stream for Zip<St1, St2> where
St1: Stream,
St2: Stream, [src]
[+]
impl<St1, St2> Stream for Zip<St1, St2> where
St1: Stream,
St2: Stream, impl<St1, St2> FusedStream for Zip<St1, St2> where
St1: Stream,
St2: Stream, [src]
[+]
impl<St1, St2> FusedStream for Zip<St1, St2> where
St1: Stream,
St2: Stream, Auto Trait Implementations
impl<St1, St2> Send for Zip<St1, St2> where
St1: Send,
St2: Send,
<St1 as Stream>::Item: Send,
<St2 as Stream>::Item: Send,
impl<St1, St2> Send for Zip<St1, St2> where
St1: Send,
St2: Send,
<St1 as Stream>::Item: Send,
<St2 as Stream>::Item: Send, impl<St1, St2> Sync for Zip<St1, St2> where
St1: Sync,
St2: Sync,
<St1 as Stream>::Item: Sync,
<St2 as Stream>::Item: Sync,
impl<St1, St2> Sync for Zip<St1, St2> where
St1: Sync,
St2: Sync,
<St1 as Stream>::Item: Sync,
<St2 as Stream>::Item: Sync, Blanket Implementations
impl<T> StreamExt for T where
T: Stream + ?Sized, [src]
[−]
impl<T> StreamExt for T where
T: Stream + ?Sized, fn next(&mut self) -> Next<Self> where
Self: Sized + Unpin, [src]
[−]
fn next(&mut self) -> Next<Self> where
Self: Sized + Unpin, Creates a future that resolves to the next item in the stream. Read more
fn into_future(self) -> StreamFuture<Self> where
Self: Sized + Unpin, [src]
[−]
fn into_future(self) -> StreamFuture<Self> where
Self: Sized + Unpin, Converts this stream into a future of (next_item, tail_of_stream). If the stream terminates, then the next item is None. Read more
fn map<T, F>(self, f: F) -> Map<Self, F> where
F: FnMut(Self::Item) -> T,
Self: Sized, [src]
[−]
fn map<T, F>(self, f: F) -> Map<Self, F> where
F: FnMut(Self::Item) -> T,
Self: Sized, Maps this stream's items to a different type, returning a new stream of the resulting type. Read more
fn filter<Fut, F>(self, f: F) -> Filter<Self, Fut, F> where
F: FnMut(&Self::Item) -> Fut,
Fut: Future<Output = bool>,
Self: Sized, [src]
[−]
fn filter<Fut, F>(self, f: F) -> Filter<Self, Fut, F> where
F: FnMut(&Self::Item) -> Fut,
Fut: Future<Output = bool>,
Self: Sized, Filters the values produced by this stream according to the provided asynchronous predicate. Read more
fn filter_map<Fut, T, F>(self, f: F) -> FilterMap<Self, Fut, F> where
F: FnMut(Self::Item) -> Fut,
Fut: Future<Output = Option<T>>,
Self: Sized, [src]
[−]
fn filter_map<Fut, T, F>(self, f: F) -> FilterMap<Self, Fut, F> where
F: FnMut(Self::Item) -> Fut,
Fut: Future<Output = Option<T>>,
Self: Sized, Filters the values produced by this stream while simultaneously mapping them to a different type according to the provided asynchronous closure. Read more
fn then<Fut, F>(self, f: F) -> Then<Self, Fut, F> where
F: FnMut(Self::Item) -> Fut,
Fut: Future,
Self: Sized, [src]
[−]
fn then<Fut, F>(self, f: F) -> Then<Self, Fut, F> where
F: FnMut(Self::Item) -> Fut,
Fut: Future,
Self: Sized, Computes from this stream's items new items of a different type using an asynchronous closure. Read more
fn collect<C: Default + Extend<Self::Item>>(self) -> Collect<Self, C> where
Self: Sized, [src]
[−]
fn collect<C: Default + Extend<Self::Item>>(self) -> Collect<Self, C> where
Self: Sized, Collect all of the values of this stream into a vector, returning a future representing the result of that computation. Read more
fn concat(self) -> Concat<Self> where
Self: Sized,
Self::Item: Extend<<Self::Item as IntoIterator>::Item> + IntoIterator + Default, [src]
[−]
fn concat(self) -> Concat<Self> where
Self: Sized,
Self::Item: Extend<<Self::Item as IntoIterator>::Item> + IntoIterator + Default, Concatenate all items of a stream into a single extendable destination, returning a future representing the end result. Read more
fn fold<T, Fut, F>(self, init: T, f: F) -> Fold<Self, Fut, T, F> where
F: FnMut(T, Self::Item) -> Fut,
Fut: Future<Output = T>,
Self: Sized, [src]
[−]
fn fold<T, Fut, F>(self, init: T, f: F) -> Fold<Self, Fut, T, F> where
F: FnMut(T, Self::Item) -> Fut,
Fut: Future<Output = T>,
Self: Sized, Execute an accumulating asynchronous computation over a stream, collecting all the values into one final result. Read more
fn flatten(self) -> Flatten<Self> where
Self::Item: Stream,
Self: Sized, [src]
[−]
fn flatten(self) -> Flatten<Self> where
Self::Item: Stream,
Self: Sized, Flattens a stream of streams into just one continuous stream. Read more
fn skip_while<Fut, F>(self, f: F) -> SkipWhile<Self, Fut, F> where
F: FnMut(&Self::Item) -> Fut,
Fut: Future<Output = bool>,
Self: Sized, [src]
[−]
fn skip_while<Fut, F>(self, f: F) -> SkipWhile<Self, Fut, F> where
F: FnMut(&Self::Item) -> Fut,
Fut: Future<Output = bool>,
Self: Sized, Skip elements on this stream while the provided asynchronous predicate resolves to true. Read more
fn take_while<Fut, F>(self, f: F) -> TakeWhile<Self, Fut, F> where
F: FnMut(&Self::Item) -> Fut,
Fut: Future<Output = bool>,
Self: Sized, [src]
[−]
fn take_while<Fut, F>(self, f: F) -> TakeWhile<Self, Fut, F> where
F: FnMut(&Self::Item) -> Fut,
Fut: Future<Output = bool>,
Self: Sized, Take elements from this stream while the provided asynchronous predicate resolves to true. Read more
fn for_each<Fut, F>(self, f: F) -> ForEach<Self, Fut, F> where
F: FnMut(Self::Item) -> Fut,
Fut: Future<Output = ()>,
Self: Sized, [src]
[−]
fn for_each<Fut, F>(self, f: F) -> ForEach<Self, Fut, F> where
F: FnMut(Self::Item) -> Fut,
Fut: Future<Output = ()>,
Self: Sized, Runs this stream to completion, executing the provided asynchronous closure for each element on the stream. Read more
fn for_each_concurrent<Fut, F>(
self,
limit: impl Into<Option<usize>>,
f: F
) -> ForEachConcurrent<Self, Fut, F> where
F: FnMut(Self::Item) -> Fut,
Fut: Future<Output = ()>,
Self: Sized, [src]
[−]
fn for_each_concurrent<Fut, F>(
self,
limit: impl Into<Option<usize>>,
f: F
) -> ForEachConcurrent<Self, Fut, F> where
F: FnMut(Self::Item) -> Fut,
Fut: Future<Output = ()>,
Self: Sized, Runs this stream to completion, executing the provided asynchronous closure for each element on the stream concurrently as elements become available. Read more
fn take(self, n: u64) -> Take<Self> where
Self: Sized, [src]
[−]
fn take(self, n: u64) -> Take<Self> where
Self: Sized, Creates a new stream of at most n items of the underlying stream. Read more
fn skip(self, n: u64) -> Skip<Self> where
Self: Sized, [src]
[−]
fn skip(self, n: u64) -> Skip<Self> where
Self: Sized, Creates a new stream which skips n items of the underlying stream. Read more
fn fuse(self) -> Fuse<Self> where
Self: Sized, [src]
[−]
fn fuse(self) -> Fuse<Self> where
Self: Sized, Fuse a stream such that poll_next will never again be called once it has finished. This method can be used t turn any Stream into a FusedStream. Read more
ⓘImportant traits for &'_ mut Ifn by_ref(&mut self) -> &mut Self where
Self: Sized, [src]
[−]
fn by_ref(&mut self) -> &mut Self where
Self: Sized, Borrows a stream, rather than consuming it. Read more
fn catch_unwind(self) -> CatchUnwind<Self> where
Self: Sized + UnwindSafe, [src]
[−]
fn catch_unwind(self) -> CatchUnwind<Self> where
Self: Sized + UnwindSafe, Catches unwinding panics while polling the stream. Read more
fn boxed(self) -> Pin<Box<Self>> where
Self: Sized, [src]
[−]
fn boxed(self) -> Pin<Box<Self>> where
Self: Sized, Wrap the stream in a Box, pinning it.
fn buffered(self, n: usize) -> Buffered<Self> where
Self::Item: Future,
Self: Sized, [src]
[−]
fn buffered(self, n: usize) -> Buffered<Self> where
Self::Item: Future,
Self: Sized, An adaptor for creating a buffered list of pending futures. Read more
fn buffer_unordered(self, n: usize) -> BufferUnordered<Self> where
Self::Item: Future,
Self: Sized, [src]
[−]
fn buffer_unordered(self, n: usize) -> BufferUnordered<Self> where
Self::Item: Future,
Self: Sized, An adaptor for creating a buffered list of pending futures (unordered). Read more
fn zip<St>(self, other: St) -> Zip<Self, St> where
St: Stream,
Self: Sized, [src]
[−]
fn zip<St>(self, other: St) -> Zip<Self, St> where
St: Stream,
Self: Sized, An adapter for zipping two streams together. Read more
fn chain<St>(self, other: St) -> Chain<Self, St> where
St: Stream<Item = Self::Item>,
Self: Sized, [src]
[−]
fn chain<St>(self, other: St) -> Chain<Self, St> where
St: Stream<Item = Self::Item>,
Self: Sized, Adapter for chaining two stream. Read more
fn peekable(self) -> Peekable<Self> where
Self: Sized, [src]
[−]
fn peekable(self) -> Peekable<Self> where
Self: Sized, Creates a new stream which exposes a peek method. Read more
fn chunks(self, capacity: usize) -> Chunks<Self> where
Self: Sized, [src]
[−]
fn chunks(self, capacity: usize) -> Chunks<Self> where
Self: Sized, An adaptor for chunking up items of the stream inside a vector. Read more
fn select<St>(self, other: St) -> Select<Self, St> where
St: Stream<Item = Self::Item>,
Self: Sized, [src]
[−]
fn select<St>(self, other: St) -> Select<Self, St> where
St: Stream<Item = Self::Item>,
Self: Sized, This combinator will attempt to pull items from both streams. Each stream will be polled in a round-robin fashion, and whenever a stream is ready to yield an item that item is yielded. Read more
fn forward<S>(self, sink: S) -> Forward<Self, S> where
S: Sink + Unpin,
Self: Stream<Item = Result<S::SinkItem, S::SinkError>> + Sized, [src]
[−]
fn forward<S>(self, sink: S) -> Forward<Self, S> where
S: Sink + Unpin,
Self: Stream<Item = Result<S::SinkItem, S::SinkError>> + Sized, A future that completes after the given stream has been fully processed into the sink, including flushing. Read more
fn split(self) -> (SplitSink<Self>, SplitStream<Self>) where
Self: Sink + Sized, [src]
[−]
fn split(self) -> (SplitSink<Self>, SplitStream<Self>) where
Self: Sink + Sized, Splits this Stream + Sink object into separate Stream and Sink objects. Read more
fn inspect<F>(self, f: F) -> Inspect<Self, F> where
F: FnMut(&Self::Item),
Self: Sized, [src]
[−]
fn inspect<F>(self, f: F) -> Inspect<Self, F> where
F: FnMut(&Self::Item),
Self: Sized, Do something with each item of this stream, afterwards passing it on. Read more
ⓘImportant traits for Either<L, R>fn left_stream<B>(self) -> Either<Self, B> where
B: Stream<Item = Self::Item>,
Self: Sized, [src]
[−]
fn left_stream<B>(self) -> Either<Self, B> where
B: Stream<Item = Self::Item>,
Self: Sized, Wrap this stream in an Either stream, making it the left-hand variant of that Either. Read more
ⓘImportant traits for Either<L, R>fn right_stream<B>(self) -> Either<B, Self> where
B: Stream<Item = Self::Item>,
Self: Sized, [src]
[−]
fn right_stream<B>(self) -> Either<B, Self> where
B: Stream<Item = Self::Item>,
Self: Sized, Wrap this stream in an Either stream, making it the right-hand variant of that Either. Read more
fn poll_next_unpin(&mut self, lw: &LocalWaker) -> Poll<Option<Self::Item>> where
Self: Unpin + Sized, [src]
[−]
fn poll_next_unpin(&mut self, lw: &LocalWaker) -> Poll<Option<Self::Item>> where
Self: Unpin + Sized, A convenience method for calling Stream::poll_next on Unpin stream types. Read more
fn select_next_some(&mut self) -> SelectNextSome<Self> where
Self: Sized + Unpin + FusedStream, [src]
[−]
fn select_next_some(&mut self) -> SelectNextSome<Self> where
Self: Sized + Unpin + FusedStream, impl<T> From for T[src]
[−]
impl<T> From for Timpl<T, U> Into for T where
U: From<T>, [src]
[−]
impl<T, U> Into for T where
U: From<T>, impl<T, U> TryFrom for T where
T: From<U>, [src]
[−]
impl<T, U> TryFrom for T where
T: From<U>, type Error = !
try_from)The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]
[−]
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>impl<T> Borrow for T where
T: ?Sized, [src]
[−]
impl<T> Borrow for T where
T: ?Sized, impl<T> Any for T where
T: 'static + ?Sized, [src]
[−]
impl<T> Any for T where
T: 'static + ?Sized, fn get_type_id(&self) -> TypeId[src]
[−]
fn get_type_id(&self) -> TypeIdimpl<T, U> TryInto for T where
U: TryFrom<T>, [src]
[−]
impl<T, U> TryInto for T where
U: TryFrom<T>, type Error = <U as TryFrom<T>>::Error
try_from)The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>[src]
[−]
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>impl<T> BorrowMut for T where
T: ?Sized, [src]
[−]
impl<T> BorrowMut for T where
T: ?Sized, ⓘImportant traits for &'_ mut Ifn borrow_mut(&mut self) -> &mut T[src]
[−]
fn borrow_mut(&mut self) -> &mut T