Определите, когда все потоки приносят пользу ⇐ Android

[Anonymous]

У меня есть две функции, которые загружают данные в базу данных.

Код: Выделить всё

suspend fun addOverallRatingValue(productId: String): Flow
suspend fun markProductAsRatedByUser(productId: String): Flow

Оба являются callbackFlow

Код: Выделить всё

override suspend fun markProductAsRatedByUser(productId: String) = callbackFlow {
try {
firebaseInstance
...
.addOnSuccessListener {
trySend(FirebaseEventResponse.SuccessSetValue)
}
.addOnFailureListener {
trySend(FirebaseEventResponse.ExceptionOccurred.Event(it))
}
} catch (e: Exception) {
trySend(FirebaseEventResponse.ExceptionOccurred.Event(e))
}
awaitClose { this.cancel() }
}

Как я могу объединить эти два потока и реагировать, когда они оба отправляют какой-либо ответ FirebaseEventResponse?

Подробнее здесь: https://stackoverflow.com/questions/721 ... uced-value