Versions in this module Expand all Collapse all v0 v0.3.0 Oct 28, 2026 Changes in this version + type Collector struct + Accumulator func(A, T) A + Combiner func(A, A) A + Finisher func(A) R + Supplier func() A + func NewCollector[T, A, R any](supplier func() A, accumulator func(A, T) A, combiner func(A, A) A, ...) Collector[T, A, R] + func NewSimpleCollector[T, R any](supplier func() R, accumulator func(R, T) R, combiner ...func(R, R) R) Collector[T, R, R] + type Collectors struct + func (Collectors) AveragingFloat64[T any](mapper func(T) float64) Collector[T, *avgAcc, float64] + func (Collectors) AveragingInt[T any](mapper func(T) int) Collector[T, *avgAcc, float64] + func (Collectors) Counting[T any]() Collector[T, *int64, int64] + func (Collectors) Filtering[T, A, R any](predicate func(T) bool, downstream Collector[T, A, R]) Collector[T, A, R] + func (Collectors) FlatMapping[T, U, A, R any](mapper func(T) []U, downstream Collector[U, A, R]) Collector[T, A, R] + func (Collectors) GroupingBy[T any, K comparable, A, D any](classifier func(T) K, downstream Collector[T, A, D]) Collector[T, map[K]A, map[K]D] + func (Collectors) Joining(delimiter string, prefixAndSuffix ...string) Collector[string, *joinAcc, string] + func (Collectors) Mapping[T, U, A, R any](mapper func(T) U, downstream Collector[U, A, R]) Collector[T, A, R] + func (Collectors) MaxBy[T any](comparator func(a, b T) int) Collector[T, *Optional[T], Optional[T]] + func (Collectors) MinBy[T any](comparator func(a, b T) int) Collector[T, *Optional[T], Optional[T]] + func (Collectors) PartitioningBy[T, A, D any](predicate func(T) bool, downstream Collector[T, A, D]) Collector[T, map[bool]A, map[bool]D] + func (Collectors) Reducing[T any](identity T, op func(T, T) T) Collector[T, *T, T] + func (Collectors) SummarizingFloat64[T any](mapper func(T) float64) Collector[T, *Float64SummaryStatistics, Float64SummaryStatistics] + func (Collectors) SummarizingInt[T any](mapper func(T) int) Collector[T, *IntSummaryStatistics, IntSummaryStatistics] + func (Collectors) SummingFloat64[T any](mapper func(T) float64) Collector[T, *float64, float64] + func (Collectors) SummingInt[T any](mapper func(T) int) Collector[T, *int64, int64] + func (Collectors) ToList[T any]() Collector[T, List[T], List[T]] + func (Collectors) ToMap[T any, K comparable, V any](keyMapper func(T) K, valueMapper func(T) V, ...) Collector[T, map[K]V, map[K]V] + func (Collectors) ToSetSlice[T comparable]() Collector[T, map[T]struct{}, []T] + func (Collectors) ToSet[T comparable]() Collector[T, Set[T], Set[T]] + func (Collectors) ToSlice[T any]() Collector[T, []T, []T] + func (this Collectors) GroupingBySlice[T any, K comparable](classifier func(T) K) Collector[T, map[K][]T, map[K][]T] + func (this Collectors) PartitioningBySlice[T any](predicate func(T) bool) Collector[T, map[bool][]T, map[bool][]T] + type Float64SummaryStatistics struct + Count int64 + Max float64 + Min float64 + Sum float64 + func NewFloat64SummaryStatistics() *Float64SummaryStatistics + func (this *Float64SummaryStatistics) Accept(value float64) + func (this *Float64SummaryStatistics) Average() float64 + func (this *Float64SummaryStatistics) Combine(other *Float64SummaryStatistics) + func (this *Float64SummaryStatistics) String() string + type IntSummaryStatistics struct + Count int64 + Max int + Min int + Sum int64 + func NewIntSummaryStatistics() *IntSummaryStatistics + func (this *IntSummaryStatistics) Accept(value int) + func (this *IntSummaryStatistics) Average() float64 + func (this *IntSummaryStatistics) Combine(other *IntSummaryStatistics) + func (this *IntSummaryStatistics) String() string + type Stream struct + func (Stream[T]) FromRangeClosed[I IntegerConstraint](startInclusive, endInclusive I) Stream[I] + func (Stream[T]) FromRange[I IntegerConstraint](startInclusive, endExclusive I) Stream[I] + func (Stream[T]) FromSeq(seq iter.Seq[T]) Stream[T] + func (this Stream[T]) AllMatch(predicate func(T) bool) bool + func (this Stream[T]) AnyMatch(predicate func(T) bool) bool + func (this Stream[T]) Close() + func (this Stream[T]) CollectWith[R any](supplier func() R, accumulator func(R, T) R, combiner ...func(R, R) R) R + func (this Stream[T]) Collect[R, A any](collector Collector[T, A, R]) R + func (this Stream[T]) Count() int64 + func (this Stream[T]) Distinct() Stream[T] + func (this Stream[T]) DistinctBy[K comparable](keySelector func(T) K) Stream[T] + func (this Stream[T]) DropWhile(predicate func(T) bool) Stream[T] + func (this Stream[T]) Filter(predicate func(T) bool) Stream[T] + func (this Stream[T]) FindAny() Optional[T] + func (this Stream[T]) FindFirst() Optional[T] + func (this Stream[T]) FlatMapSeq[R any](mapper func(T) iter.Seq[R]) Stream[R] + func (this Stream[T]) FlatMapSlice[R any](mapper func(T) []R) Stream[R] + func (this Stream[T]) FlatMap[R any](mapper func(T) Stream[R]) Stream[R] + func (this Stream[T]) ForEach(action func(T)) + func (this Stream[T]) ForEachOrdered(action func(T)) + func (this Stream[T]) From(elements ...T) Stream[T] + func (this Stream[T]) FromChan(ch <-chan T) Stream[T] + func (this Stream[T]) FromCollection(c Collection[T]) Stream[T] + func (this Stream[T]) FromConcat(a, b Stream[T]) Stream[T] + func (this Stream[T]) FromEmpty() Stream[T] + func (this Stream[T]) FromGenerate(supplier func() T) Stream[T] + func (this Stream[T]) FromIterate(seed T, f func(T) T) Stream[T] + func (this Stream[T]) FromIterateWithPredicate(seed T, hasNext func(T) bool, f func(T) T) Stream[T] + func (this Stream[T]) FromSlice(slice []T) Stream[T] + func (this Stream[T]) IsParallel() bool + func (this Stream[T]) Limit(maxSize int64) Stream[T] + func (this Stream[T]) Map[R any](mapper func(T) R) Stream[R] + func (this Stream[T]) Max(comparator ...func(a, b T) int) Optional[T] + func (this Stream[T]) MaxBy[K OrderedConstraint](keySelector func(T) K) Optional[T] + func (this Stream[T]) Min(comparator ...func(a, b T) int) Optional[T] + func (this Stream[T]) MinBy[K OrderedConstraint](keySelector func(T) K) Optional[T] + func (this Stream[T]) NoneMatch(predicate func(T) bool) bool + func (this Stream[T]) OnClose(handler func()) Stream[T] + func (this Stream[T]) Parallel() Stream[T] + func (this Stream[T]) Peek(action func(T)) Stream[T] + func (this Stream[T]) Reduce(accumulator func(a, b T) T) Optional[T] + func (this Stream[T]) ReduceWithIdentity(identity T, accumulator func(a, b T) T) T + func (this Stream[T]) ReduceWithInitial[R any](identity R, accumulator func(R, T) R) R + func (this Stream[T]) Seq() iter.Seq[T] + func (this Stream[T]) Sequential() Stream[T] + func (this Stream[T]) Skip(n int64) Stream[T] + func (this Stream[T]) Sorted(comparator ...func(a, b T) int) Stream[T] + func (this Stream[T]) SortedByDesc[K OrderedConstraint](keySelector func(T) K) Stream[T] + func (this Stream[T]) SortedBy[K OrderedConstraint](keySelector func(T) K) Stream[T] + func (this Stream[T]) SortedFunc(less func(a, b T) bool) Stream[T] + func (this Stream[T]) TakeWhile(predicate func(T) bool) Stream[T] + func (this Stream[T]) ToSlice() []T + func (this Stream[T]) Unordered() Stream[T]
Go to main page