Closed andrewbanchich closed 1 year ago
Any progress on this?
You can effectively recreate the for_each_concurrent
combinator by spawning each future into an executor, collecting those task handles into a list and then polling those task handles. This is the recommended solution, especially since the futures
implementation has footguns in it.
I'm moving from
futures
tofutures-lite
but noticed this is missingStreamExt::for_each_concurrent
.