stream

Aug 13, 2023

Changes in this version

+ type Stream struct

+ func Concat(a, b Stream[T]) Stream[T]

+ func FromChannel(source <-chan T) Stream[T]

+ func FromRange(start, end, step T) Stream[T]

+ func FromSlice(source []T) Stream[T]

+ func Generate(generator func() func() (item T, ok bool)) Stream[T]

+ func Of(elems ...T) Stream[T]

+ func (s Stream[T]) AllMatch(predicate func(item T) bool) bool

+ func (s Stream[T]) AnyMatch(predicate func(item T) bool) bool

+ func (s Stream[T]) Count() int

+ func (s Stream[T]) Distinct() Stream[T]

+ func (s Stream[T]) Filter(predicate func(item T) bool) Stream[T]

+ func (s Stream[T]) FindFirst() (T, bool)

+ func (s Stream[T]) FindLast() (T, bool)

+ func (s Stream[T]) ForEach(action func(item T))

+ func (s Stream[T]) Limit(maxSize int) Stream[T]

+ func (s Stream[T]) Map(mapper func(item T) T) Stream[T]

+ func (s Stream[T]) Max(less func(a, b T) bool) (T, bool)

+ func (s Stream[T]) Min(less func(a, b T) bool) (T, bool)

+ func (s Stream[T]) NoneMatch(predicate func(item T) bool) bool

+ func (s Stream[T]) Peek(consumer func(item T)) Stream[T]

+ func (s Stream[T]) Range(start, end int) Stream[T]

+ func (s Stream[T]) Reduce(initial T, accumulator func(a, b T) T) T

+ func (s Stream[T]) Reverse() Stream[T]

+ func (s Stream[T]) Skip(n int) Stream[T]

+ func (s Stream[T]) Sorted(less func(a, b T) bool) Stream[T]

+ func (s Stream[T]) ToSlice() []T