arrow-fx-coroutines / arrow.fx.coroutines.stream / parJoinUnbounded
parJoinUnbounded
fun <O> Stream<Stream<O>>.parJoinUnbounded(ctx: CoroutineContext = Dispatchers.Default): Stream<O>
Like parJoin but races all inner streams simultaneously without limit.