futures_concurrency/stream/zip/
mod.rs

1use futures_core::Stream;
2
3pub(crate) mod array;
4pub(crate) mod tuple;
5#[cfg(feature = "alloc")]
6pub(crate) mod vec;
7
8/// ‘Zips up’ multiple streams into a single stream of pairs.
9pub trait Zip {
10    /// What's the return type of our stream?
11    type Item;
12
13    /// What stream do we return?
14    type Stream: Stream<Item = Self::Item>;
15
16    /// Combine multiple streams into a single stream.
17    fn zip(self) -> Self::Stream;
18}