Macro stream 

macro_rules! stream {
    ($expr:expr) => { ... };
    ($expr:expr, label = $label:expr) => { ... };
    ($expr:expr, log = true) => { ... };
    ($expr:expr, label = $label:expr, log = true) => { ... };
    ($expr:expr, log = true, label = $label:expr) => { ... };
}

Instrument a stream to track its item yields.

Examples

use futures::stream::{self, StreamExt};
use channels_console::stream;

#[tokio::main]
async fn main() {
    // Create a stream
    let s = stream::iter(1..=10);

    // Instrument it
    let s = stream!(s);

    // Use it normally
    let _items: Vec<_> = s.collect().await;
}

See the stream! macro documentation for full usage details.