stream

Apr 11, 2025

Changes in this version

+ func Collect[E any, R any](s *Stream[E], collector func(iter.Seq[E]) R) R

+ func GroupBy[E any, K comparable](s *Stream[E], classifier func(E) K) map[K][]E

+ func ToMap[E any, K comparable, V any](s *Stream[E], mapper func(E) (K, V)) map[K]V

+ type MapEntry struct

+ Key K

+ Value V

+ type Stream struct

+ func Concat[E any](streams ...*Stream[E]) *Stream[E]

+ func FromMap[K comparable, V any](m map[K]V) *Stream[MapEntry[K, V]]

+ func FromSlice[E any](slice []E) *Stream[E]

+ func Map[E any, R any](s *Stream[E], mapper func(E) R) *Stream[R]

+ func NewStream[E any](it iter.Seq[E]) *Stream[E]

+ func (s *Stream[E]) Distinct() *Stream[E]

+ func (s *Stream[E]) Filter(predicate func(E) bool) *Stream[E]

+ func (s *Stream[E]) FindFirst(predicate func(E) bool) *E

+ func (s *Stream[E]) Limit(count int) *Stream[E]

+ func (s *Stream[E]) Max(less func(E, E) bool) *E

+ func (s *Stream[E]) Min(less func(E, E) bool) *E

+ func (s *Stream[E]) Peek(action func(E)) *Stream[E]

+ func (s *Stream[E]) Skip(n int) *Stream[E]

+ func (s *Stream[E]) Sorted(less func(E, E) bool) *Stream[E]

+ func (s *Stream[E]) ToSlice() []E