Hi! I currently have this pipeline: `val input: Flow<MyObject> = ... val output = input.map {...

# coroutines

[CLOVIS]

Hi!

I currently have this pipeline:

val input: Flow<MyObject> = ...
val output = input.map { it.toOtherObject() }

I would like the calls to toOtherObject to be ran in parallel, and I would like an exception in one call not to stop the others.

I tried:

val scope = CoroutineScope(SupervisorJob() + Dispatchers.Default)
val output = input.map {
  scope.async {
    it.toOtherObject()
  }
}.map { it.await() }

But this is still sequential, and not parallel. What am I doing wrong?

[Luis Munoz]

show how you are doing the collection

[Luis Munoz]

flows need a terminating operator

[CLOVIS]

I'm joining multiple of such flows with flatMapConcat, and then `collect`ing the result.

[CLOVIS]

I see, using flatMapMerge solves the concurrency issue, however it doesn't allow me to pass a SupervisorScope

[taer]

put a try/catch around the toOtherObject call? return null in the catch and later on mapNotNull?