Versions in this module Expand all Collapse all v0 v0.1.1 Jul 16, 2024 v0.1.0 Nov 18, 2022 Changes in this version + func Collect(st Stream[T], identity A, accumulator func(A, T)) A + func Distinct() func(T) bool + func DistinctUsing(mapper func(T) C) func(T) bool + func NaturalOrder(a, b T) bool + func ReverseOrder(a, b T) bool + type Stream interface + AllMatch func(predicate func(element T) bool) bool + AnyMatch func(predicate func(element T) bool) bool + Append func(Stream[T]) Stream[T] + Count func() int + Filter func(predicate func(element T) bool) Stream[T] + FindFirst func() (T, bool) + FlatMap func(mapper func(element T) Stream[T]) Stream[T] + ForEach func(consumer func(element T)) + Limit func(n int) Stream[T] + Map func(mapper func(element T) T) Stream[T] + Max func(less func(T, T) bool) (T, bool) + Min func(less func(T, T) bool) (T, bool) + NoneMatch func(predicate func(element T) bool) bool + Peek func(consumer func(element T)) Stream[T] + Reduce func(accumulator func(T, T) T) (T, bool) + Skip func(n int) Stream[T] + Sorted func(less func(T, T) bool) Stream[T] + ToSlice func() []T + func FlatMap(st Stream[T], mapper func(element T) Stream[R]) Stream[R] + func Generate(generator func() T) Stream[T] + func Iterate(seed T, operator func(T) T) Stream[T] + func Map(st Stream[T], mapper func(element T) R) Stream[R] + func Of(x ...T) Stream[T] + func Slice(x []T) Stream[T] + func While(hasNext func() bool, supplier func() T) Stream[T]