https://docs.rs/futures-async-stream/latest/futures_async_stream/index.html