·
2 commits
to master
since this release
Simplified structured concurrency Fanout API:
concurrently()cancellable.withMaxConcurrency(maxConcurrency).inParallel(...)cancellable.concurrently()throws unchecked exception so is easy to use in Stream.