dave08
01/21/2020, 5:18 PMflowOn
here:
inline fun <reified T : Any, reified R : Any> Flow<T>.concurrentMap(
dispatcher: CoroutineDispatcher = <http://Dispatchers.IO|Dispatchers.IO>,
crossinline mapFun: suspend (T) -> R
)Flow<R> = flatMapMerge {
flow { emit(mapFun(it)) }.flowOn(dispatcher)
}
?Zach Klippenstein (he/him) [MOD]
01/21/2020, 6:52 PMdave08
01/21/2020, 8:43 PMZach Klippenstein (he/him) [MOD]
01/21/2020, 8:49 PMMain
or Default
).