Macro async_std::stream::join

macro_rules! join {
    ($ stream1 : ident, $ stream2 : ident, $ ($ stream : ident), * $ (,) ?) => { ... };
}

This is supported on unstable only.

Combines multiple streams into a single stream of all their outputs.

This macro is only usable inside of async functions, closures, and blocks.

Examples

use async_macros::join_stream as join;
use futures::stream::{self, StreamExt};
use futures::future::ready;

let a = stream::once(ready(1u8));
let b = stream::once(ready(2u8));
let c = stream::once(ready(3u8));

let mut s = join!(a, b, c);

assert_eq!(s.next().await, Some(1u8));
assert_eq!(s.next().await, Some(2u8));
assert_eq!(s.next().await, Some(3u8));
assert_eq!(s.next().await, None);