Hi everyone!! Please tell me. Can Rx execute parallel processing like awaitAll of Kotlin coroutine? ...

# rx

[Matsushita Kohei]

Hi everyone!!
Please tell me. Can Rx execute parallel processing like awaitAll of Kotlin coroutine?
I think it is similar to "zip" but it can't use List<T>.
I'm waiting for messages. thanks.

[Zach Klippenstein (he/him) [MOD]]

The merge or flatMap operators are probably the closest to awaitAll.

[Matsushita Kohei]

Thank you:)

[ursus]

I'd say combineLatest().take(1)

[ursus]

zip is fine as well, just take 1 it

[ursus]

and subscribe each observable on "its own" io scheduler, then youll get parallelism

[pg]

There is also parallel flowable, but without it you have flatmap, additionally with Max concurrency parameter

[pg]

Some example here https://www.nurkiewicz.com/2017/09/idiomatic-concurrency-flatmap-vs.html?m=1