william
10/25/2020, 6:28 PMFlow<List<T>>
, can i convert it to Flow<T>
with something like flatten
on arrays on std lib?bezrukov
10/25/2020, 6:50 PMflow.flattenConcat()
william
10/25/2020, 6:58 PMbezrukov
10/25/2020, 7:20 PMflow.map { it.asFlow() }.flattenConcat()
Or
flow.flatMapConcat { it.asFlow() }
louiscad
10/25/2020, 8:25 PMfun <T> Flow<List<T>>.flattened(): Flow<T> = flow {
collect { list ->
list.forEach { emit(it) }
}
}
william
10/25/2020, 9:14 PMflorent
10/26/2020, 10:36 PMlouiscad
10/26/2020, 10:52 PMcollect
florent
10/26/2020, 11:41 PMlouiscad
10/27/2020, 7:12 AMemit
can be called on a different thread if you use flowOn