arrow-collectors/arrow.collectors/NonSuspendCollectorI

NonSuspendCollectorI

interface NonSuspendCollectorI<InternalAccumulator, in Value, out Result> : CollectorI<InternalAccumulator, Value, Result> (source)

Properties

Link copied to clipboard

Functions

Link copied to clipboard
open suspend override fun accumulate(current: InternalAccumulator, value: Value)
Link copied to clipboard
abstract fun accumulateNonSuspend(current: InternalAccumulator, value: Value)
Link copied to clipboard
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.

Link copied to clipboard
open fun <P> contramapNonSuspend(transform: (P) -> Value): NonSuspendCollector<P, Result>

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

Link copied to clipboard
open suspend override fun finish(current: InternalAccumulator): Result
Link copied to clipboard
abstract fun finishNonSuspend(current: InternalAccumulator): Result
Link copied to clipboard
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.

Link copied to clipboard
open fun <S> mapNonSuspend(transform: (Result) -> S): NonSuspendCollector<Value, S>

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

Link copied to clipboard
open suspend override fun supply(): InternalAccumulator
Link copied to clipboard
Link copied to clipboard
open fun <B, S> zip(other: CollectorI<B, Value, S>): Collector<Value, Pair<Result, S>>
open fun <B, S> zip(other: NonSuspendCollectorI<B, @UnsafeVariance Value, S>): NonSuspendCollector<Value, Pair<Result, S>>

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.

Link copied to clipboard
open fun <B, S, V> zipNonSuspend(other: NonSuspendCollectorI<B, @UnsafeVariance Value, S>, combine: (Result, S) -> V): NonSuspendCollector<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.