Asynchronous streams for Rust using async & await notation - tokio-rs/async-stream