Macro stream 

stream!() { /* proc-macro */ }

The stream! macro for creating order-independent streams.

Examples

let elapsed = stream!(cx, || {
    (0..).inspect(|_| std::thread::sleep(Duration::from_secs(1)))
});