bindReducing

fun <A> bindReducing(source: Flow<A>, onError: (Throwable) -> Unit = { throw it }, reduce: suspend (T?, A) -> T): Job(source)

Accumulates, merges or replaces data using a consumer-defined reducer.