stream

package

Go to main page

Versions in this module

v1

v1.1.3

Nov 26, 2024

Changes in this version

type Stream

+ func (s Stream[T]) Joining(seq string) string

v1.1.2

Aug 7, 2024

Changes in this version

+ func RequireNonNil(obj any)

type Optional

+ func OfOptionalNilable[T any](t *T) Optional[T]

+ func OfOptional[T any](t *T) Optional[T]

+ func (o Optional[T]) OrElse(other T) T

+ func (o Optional[T]) OrElseGet(fn func() T) T

type Stream

+ func (s Stream[T]) DropWhile(fn func(item T) bool) Stream[T]

+ func (s Stream[T]) TakeWhile(fn func(item T) bool) Stream[T]

v1.1.1

May 11, 2024

Changes in this version

type Stream

+ func (s Stream[T]) PeekP(fn func(item T)) Stream[T]

v1.1.0

Nov 26, 2023

Changes in this version

+ func Collect[T any, A any, R any](s Stream[T], collector collectors.Collector[T, A, R]) R

type Stream

+ func (s Stream[T]) SumFloat32Statistics() SumFloatStatistics[float32]

+ func (s Stream[T]) ToMapInt(keyMapper func(T) int, valueMapper func(T) T, opts ...func(oldV, newV T) T) map[int]T

+ func (s Stream[T]) ToMapString(keyMapper func(T) string, valueMapper func(T) T, opts ...func(oldV, newV T) T) map[string]T

v1.0.5

Nov 15, 2023

Changes in this version

+ func GroupingBy[T any, K string | int | int32 | int64, R any](s Stream[T], keyMapper func(T) K, valueMapper func(T) R, opts ...OptFunc[R]) map[K][]R

+ type OptFunc func([]T)

type Stream

+ func (s Stream[T]) GroupingByInt(groupFunc func(T) int, opts ...OptFunc[T]) map[int][]T

+ func (s Stream[T]) GroupingByString(groupFunc func(T) string, opts ...OptFunc[T]) map[string][]T

v1.0.4

Nov 4, 2023

Changes in this version

type Stream

+ func (s Stream[T]) FlatMapToFloat32(mapper func(T) Stream[float32]) Stream[float32]

+ func (s Stream[T]) FlatMapToFloat64(mapper func(T) Stream[float64]) Stream[float64]

+ func (s Stream[T]) FlatMapToInt32(mapper func(T) Stream[int32]) Stream[int32]

+ func (s Stream[T]) FlatMapToInt64(mapper func(T) Stream[int64]) Stream[int64]

+ func (s Stream[T]) MapToFloat32(mapper func(T) float32) Stream[float32]

+ func (s Stream[T]) MapToFloat64(mapper func(T) float64) Stream[float64]

+ func (s Stream[T]) MapToInt32(mapper func(T) int32) Stream[int32]

+ func (s Stream[T]) MapToInt64(mapper func(T) int64) Stream[int64]

+ func (s Stream[T]) SumFloat64Statistics() SumFloatStatistics[float64]

+ func (s Stream[T]) SumFloatStatistics() SumFloatStatistics[float32]

+ func (s Stream[T]) SumInt32Statistics() SumIntStatistics[int32]

+ func (s Stream[T]) SumInt64Statistics() SumIntStatistics[int64]

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

+ type SumFloatStatistics struct

+ Average float64

+ Count int64

+ Max T

+ Min T

+ Sum float64

+ func (s SumFloatStatistics[T]) GetAverage() float64

+ func (s SumFloatStatistics[T]) GetCount() int64

+ func (s SumFloatStatistics[T]) GetMax() T

+ func (s SumFloatStatistics[T]) GetMin() T

+ func (s SumFloatStatistics[T]) GetSum() float64

+ type SumIntStatistics struct

+ Average float64

+ Count int64

+ Max T

+ Min T

+ Sum int64

+ func (s SumIntStatistics[T]) GetAverage() float64

+ func (s SumIntStatistics[T]) GetCount() int64

+ func (s SumIntStatistics[T]) GetMax() T

+ func (s SumIntStatistics[T]) GetMin() T

+ func (s SumIntStatistics[T]) GetSum() int64

v1.0.3

Nov 4, 2023

Changes in this version

type Stream

+ func (s Stream[T]) FlatMapToString(mapper func(T) Stream[string]) Stream[string]

+ func (s Stream[T]) MapToString(mapper func(T) string) Stream[string]

v1.0.2

Oct 30, 2023

v1.0.1

Oct 30, 2023

v1.0.0

Apr 5, 2023

Changes in this version

+ func GoSafe(fn func())

+ func Recover(cleanups ...func())

+ func RunSafe(fn func())

+ type Optional struct

+ func (o Optional[T]) Get() (v T, ok bool)

+ func (o Optional[T]) IfPresent(fn func(T))

+ func (o Optional[T]) IsPresent() bool

+ type Stream struct

+ func Concat(s Stream[T], others ...Stream[T]) Stream[T]

+ func FlatMap(s Stream[T], mapper func(T) Stream[R]) Stream[R]

+ func Map(s Stream[T], mapper func(T) R) Stream[R]

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

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

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

+ func OfParallel(values ...T) Stream[T]

+ func Range(source <-chan T, isParallel bool) Stream[T]

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

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

+ func (s Stream[T]) Collect(collector collectors.Collector[T, T, any]) any

+ func (s Stream[T]) Concat(others ...Stream[T]) Stream[T]

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

+ func (s Stream[T]) Distinct(fn func(item T) any) Stream[T]

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

+ func (s Stream[T]) FindFirst() Optional[T]

+ func (s Stream[T]) FindLast() Optional[T]

+ func (s Stream[T]) FlatMap(mapper func(T) Stream[any]) Stream[any]

+ func (s Stream[T]) FlatMapToDouble(mapper func(T) Stream[float64]) Stream[float64]

+ func (s Stream[T]) FlatMapToInt(mapper func(T) Stream[any]) Stream[any]

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

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

+ func (s Stream[T]) Map(fn func(item T) any) Stream[any]

+ func (s Stream[T]) MapToDouble(mapper func(T) float64) Stream[float64]

+ func (s Stream[T]) MapToInt(mapper func(T) int64) Stream[int64]

+ func (s Stream[T]) Max(comparator func(T, T) int) Optional[T]

+ func (s Stream[T]) Min(comparator func(T, T) int) Optional[T]

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

+ func (s Stream[T]) Peek(fn func(item *T)) Stream[T]

+ func (s Stream[T]) Reduce(accumulator func(T, T) T) Optional[T]

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

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

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

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

+ func (s Stream[T]) Walk(fn func(item T, pipe chan<- T)) Stream[T]

v1.0.0-beta

Apr 4, 2023

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL