arrow-collectors/arrow.collectors/Collectors

Collectors

object Collectors(source)

Library of Collectors.

Properties

val length: NonSuspendCollector<Any?, Int>

Counts the number of elements in the flow.

val sum: NonSuspendCollector<Int, Int>

Sum of all the values in the flow.

Functions

fun <M> bestBy(selectNew: (old: M, new: M) -> Boolean): NonSuspendCollector<M, M?>

Returns the "best" value from the value.

fun <K, V> Collectors.concurrentMap(): NonSuspendCollector<Pair<K, V>, ConcurrentMap<K, V>>

Collects all the values in a map.

concurrentMapFromEntries

fun <K, V> Collectors.concurrentMapFromEntries(): NonSuspendCollector<Map.Entry<K, V>, ConcurrentMap<K, V>>

Collects all the values in a map.

fun <T> Collectors.concurrentSet(): NonSuspendCollector<T, Set<T>>

Collects all the values in a set.

fun <R> constant(value: R): NonSuspendCollector<Any?, R>

Returns always the same value, regardless of the collected flow.

fun intReducer(initial: () -> Int, combine: (Int, Int) -> Int): NonSuspendCollector<Int, Int>

fun <T, R> Collectors.jvm(collector: Collector<T, *, R>): NonSuspendCollector<T, R>

Wraps a java.util.stream.Collector to use with collect.

fun <T> list(): NonSuspendCollector<T, List<T>>

Collects all the values in a list, in the order in which they are emitted.

fun <K, V> map(): NonSuspendCollector<Pair<K, V>, Map<K, V>>

Collects all the values in a map.

fun <K, V> mapFromEntries(): NonSuspendCollector<Map.Entry<K, V>, Map<K, V>>

Collects all the values in a map.

fun <M> reducer(initial: () -> M, combine: (M, M) -> M, unordered: Boolean = false): NonSuspendCollector<M, M>

fun <T> set(): NonSuspendCollector<T, Set<T>>

Collects all the values in a set.