my flow is `Flow<List<T>>`, can i convert it to `Flow<T>` with something like `fl...

# coroutines

[william]

my flow is Flow<List<T>>, can i convert it to Flow<T> with something like flatten on arrays on std lib?

[bezrukov]

flow.flattenConcat()

[william]

the docs say "Flattens the given flow of flows into a single flow" so that isn't quite right i don't think

[bezrukov]

you need to map lists to flows before,
flow.map { it.asFlow() }.flattenConcat()

Or
flow.flatMapConcat { it.asFlow() }

[louiscad]

fun <T> Flow<List<T>>.flattened(): Flow<T> = flow {
    collect { list ->
        list.forEach { emit(it) }
    }
}

[louiscad]

@william The extension above can do.

[william]

thanks guys!

[florent]

Hum when you do that collect in which thread is that code executed?

[louiscad]

@florent One of the threads of the dispatcher running the coroutine that calls collect

[florent]

If the terminal operator of that stream is a collect that emit on the UI thread, would the collect of that function also be executed on the UI thread?

[louiscad]

emit can be called on a different thread if you use flowOn