futures_concurrency/stream/chain/
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/// Takes multiple streams and creates a new stream over all in sequence.
9pub trait Chain {
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 chain(self) -> Self::Stream;
18}