Saiedmomen
04/05/2022, 7:03 AMpublic inline fun <reified T, R> combine(
flows: Iterable<Flow<T>>,
crossinline transform: suspend (Array<T>) -> R
): Flow<R> {
val flowArray = flows.toList().toTypedArray()
return flow {
combineInternal(
flowArray,
arrayFactory = { arrayOfNulls(flowArray.size) },
transform = { emit(transform(it)) })
}
}
Lee Taehoon
04/06/2022, 12:53 AMSaiedmomen
04/13/2022, 6:59 AM