NonSuspendCollectorI

Properties

open suspend override fun accumulate(current: InternalAccumulator, value: Value)

open fun <P> contramap(transform: suspend (P) -> Value): Collector<P, Result>

Applies a function over each element in the data source, before giving it to the collector.

Applies a function over each element in the data source, before giving it to the collector.

open suspend override fun finish(current: InternalAccumulator): Result

open fun <S> map(transform: suspend (Result) -> S): Collector<Value, S>

Performs additional work during the finalization phase, by applying a function to the end result.

Performs additional work during the finalization phase, by applying a function to the end result.

open suspend override fun supply(): InternalAccumulator

Combines two Collectors by performing the phases of each of them in parallel.

open fun <B, S, V> zip(other: CollectorI<B, Value, S>, combine: suspend (Result, S) -> V): Collector<Value, V>

Combines two Collectors by performing the phases of each of them in parallel, and then combining the end result in a final step.

Combines two Collectors by performing the phases of each of them in parallel, and then combining the end result in a final step.