stream

type DoChunkFunc[V any] func(from, to int, chunk []V) error

type DoFunc[V any] func(i int, a V) error

type EqFunc[V any] func(i int, a V, j int, b V) bool

type ExpandFunc[V any] func(i int, a V) []V

type ExtractComparableKeyFunc[V any, K comparable] func(i int, a V) K

type ExtractKeyFunc[V any] func(i int, a V) interface{}

type FilterFunc[V any] func(i int, a V) bool

type MergeValuesFunc[V any, W any, VW any] func(okV bool, v V, okW bool, w W) []VW

type PeekFunc[V any] func(i int, a V)

type SortFunc[V any] func(i int, a V, j int, b V) bool

type Stream[V any] interface {
	First() (V, bool)
	FirstBy(checkValues FilterFunc[V]) (int, V, bool)
	Last() (V, bool)
	LastBy(checkValues FilterFunc[V]) (int, V, bool)
	Count() int
	AllMatch(checkValues FilterFunc[V]) bool
	AnyMatch(checkValues FilterFunc[V]) bool
	NoneMatch(checkValues FilterFunc[V]) bool
	ForEach(do DoFunc[V]) error
	ForEachAsync(do DoFunc[V]) error
	ForEachChunk(chunkSize int, do DoChunkFunc[V]) error
	ForEachChunkAsync(chunkSize int, do DoChunkFunc[V]) error
	Get() []V
	Reverse() Stream[V]
	Sort(sortValues SortFunc[V]) Stream[V]
	Filter(checkValues FilterFunc[V]) Stream[V]
	Peek(peekValues PeekFunc[V]) Stream[V]
	Expand(remap ExpandFunc[V]) Stream[V]
	Limit(int) Stream[V]
	Skip(int) Stream[V]
	Distinct(compareValues EqFunc[V]) Stream[V]
	DistinctByKey(distinctKey ExtractKeyFunc[V]) Stream[V]
}

type WrapValueFunc[V any, NV any] func(i int, value V) []NV