kotlinx-coroutines-core / kotlinx.coroutines.experimental.channels / reduce

reduce

inline suspend fun <S, E : S> ReceiveChannel<E>.reduce(
    operation: (acc: S, E) -> S
): S (source)

Platform and version requirements: JVM

Accumulates value starting with the first element and applying operation from left to right to current accumulator value and each element.

The operation is terminal. This function consumes all elements of the original ReceiveChannel.