Concurrency
Processing a Stream With Buffer Unordered in Rust Explained
buffer_unordered runs up to N futures from a stream at once and yields results as they finish. See bounded fan out, error handling and how it differs from join_all.
6 min read
Tag
streams
2 posts
Concurrency
Streams in Rust With Futures and Tokio Stream Explained
A Stream is the async version of Iterator. See next().await, StreamExt adapters, creating streams from channels and iterators, and where Stream is headed.
7 min read