Support for Stream::for_each_concurrent()?
Open
api design
- Dominant language
- Rust
- Stars
- 4.1k
- Forks
- 339
- PR merge metrics
- No merged PRs in 30d
Description
futures has a method for_each_concurrent() on StreamExt. It functions basically the same as for_each() but the future to be executed doesn't block the stream. Is it possible to implement the function in async-std as well?
Contributor guide
Assessment
This issue has not been assessed yet.