Collectors

Library of Collectors.

Properties

Counts the number of elements in the flow.

Sum of all the values in the flow.

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>, ERROR CLASS: Symbol not found for ConcurrentMap>

Collects all the values in a map.

fun <K, V> Collectors.concurrentMapFromEntries(): NonSuspendCollector<Map.Entry<K, V>, ERROR CLASS: Symbol not found for ConcurrentMap>

Collects all the values in a map.

Collects all the values in a set.

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

fun <T, R> Collectors.jvm(collector: ERROR CLASS: Symbol not found for java.util.stream.Collector): NonSuspendCollector<T, R>

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

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

Collects all the values in a map.

Collects all the values in a map.

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

Collects all the values in a set.