Versions in this module Expand all Collapse all v0 v0.1.0 Aug 29, 2026 Changes in this version + func Chunk[T any](n int) func(Flow[T]) Flow[[]T] + func Contains[T comparable](f Flow[T], v T) bool + func False[T any](T) bool + func Identity[T any](t T) T + func True[T any](T) bool + type Chain struct + func Compose[T0, T1 any](f Fp[T0, T1]) Chain[T0, T1] + func (c Chain[T0, T1]) Run(t0 T0) T1 + func (c Chain[T0, T1]) Then[T2 any](g Fp[T1, T2]) Chain[T0, T2] + type Fe = func(T) (U, error) + func ErrOnNone[T, U any](f Fp[T, Optional[U]], err error) Fe[T, U] + func NilError[T, U any](f Fp[T, U]) Fe[T, U] + type Flow struct + func Distinct[T comparable](f Flow[T]) Flow[T] + func FromFn[T any](n int, fn func(int) T) Flow[T] + func FromSeq[T any](seq iter.Seq[T]) Flow[T] + func From[T any](s ...T) Flow[T] + func Zip[T, U any](a Flow[T], b Flow[U]) Flow[Pair[T, U]] + func (f Flow[T]) All(pred func(T) bool) bool + func (f Flow[T]) Any(pred func(T) bool) bool + func (f Flow[T]) Cache() Flow[T] + func (f Flow[T]) Concat(others ...Flow[T]) Flow[T] + func (f Flow[T]) Count() int + func (f Flow[T]) DistinctBy[K comparable](key func(T) K) Flow[T] + func (f Flow[T]) Drop(n int) Flow[T] + func (f Flow[T]) DropWhile(pred func(T) bool) Flow[T] + func (f Flow[T]) Filter(pred func(T) bool) Flow[T] + func (f Flow[T]) Find(pred func(T) bool) Optional[T] + func (f Flow[T]) First() Optional[T] + func (f Flow[T]) FlatMap[U any](fn func(T) Flow[U]) Flow[U] + func (f Flow[T]) Fold[U any](init U, fn func(U, T) U) U + func (f Flow[T]) ForEach(fn func(T)) + func (f Flow[T]) ForEachIndexed(fn func(int, T)) + func (f Flow[T]) GroupBy[K comparable](key func(T) K) map[K][]T + func (f Flow[T]) IsEmpty() bool + func (f Flow[T]) Last() Optional[T] + func (f Flow[T]) MapIndexed[U any](fn func(int, T) U) Flow[U] + func (f Flow[T]) Map[U any](fn func(T) U) Flow[U] + func (f Flow[T]) MaxBy[K cmp.Ordered](key func(T) K) Optional[T] + func (f Flow[T]) MinBy[K cmp.Ordered](key func(T) K) Optional[T] + func (f Flow[T]) Partition(pred func(T) bool) (matched, rest Flow[T]) + func (f Flow[T]) Reduce(fn func(T, T) T) Optional[T] + func (f Flow[T]) Reverse() Flow[T] + func (f Flow[T]) Seq() iter.Seq[T] + func (f Flow[T]) Slice() []T + func (f Flow[T]) SortBy[K cmp.Ordered](key func(T) K) Flow[T] + func (f Flow[T]) SortFunc(cmp func(a, b T) int) Flow[T] + func (f Flow[T]) Take(n int) Flow[T] + func (f Flow[T]) TakeWhile(pred func(T) bool) Flow[T] + func (f Flow[T]) ToMap[K comparable](key func(T) K) map[K]T + func (f Flow[T]) To[U any](fn func(Flow[T]) U) U + type Fp = func(T) U + func And[T any](preds ...Fp[T, bool]) Fp[T, bool] + func AtLeast[T cmp.Ordered](r T) Fp[T, bool] + func AtMost[T cmp.Ordered](r T) Fp[T, bool] + func Between[T cmp.Ordered](x, y T) Fp[T, bool] + func Const[T, U any](u U) Fp[T, U] + func Equal[T comparable](x T) Fp[T, bool] + func GreaterThan[T cmp.Ordered](r T) Fp[T, bool] + func IgnoreError[T, U any](f Fe[T, U], orElse U) Fp[T, U] + func Implies[T any](l, r Fp[T, bool]) Fp[T, bool] + func LessThan[T cmp.Ordered](r T) Fp[T, bool] + func Nand[T any](l, r Fp[T, bool]) Fp[T, bool] + func Nor[T any](l, r Fp[T, bool]) Fp[T, bool] + func Not[T any](pred Fp[T, bool]) Fp[T, bool] + func OneOf[T comparable](vs ...T) Fp[T, bool] + func Or[T any](preds ...Fp[T, bool]) Fp[T, bool] + func PanicOnError[T, U any](f Fe[T, U]) Fp[T, U] + func Xnor[T any](l, r Fp[T, bool]) Fp[T, bool] + func Xor[T any](l, r Fp[T, bool]) Fp[T, bool] + type Optional struct + func FromPtr[T any](p *T) Optional[T] + func FromResult[T any](v T, err error) Optional[T] + func None[T any]() Optional[T] + func Some[T any](v T) Optional[T] + func (o *Optional[T]) UnmarshalJSON(data []byte) error + func (o Optional[T]) AsFlow() Flow[T] + func (o Optional[T]) Filter(pred func(T) bool) Optional[T] + func (o Optional[T]) FlatMap[U any](fn func(T) Optional[U]) Optional[U] + func (o Optional[T]) ForEach(fn func(T)) + func (o Optional[T]) Get() (T, bool) + func (o Optional[T]) IsEmpty() bool + func (o Optional[T]) IsPresent() bool + func (o Optional[T]) IsZero() bool + func (o Optional[T]) Map[U any](fn func(T) U) Optional[U] + func (o Optional[T]) MarshalJSON() ([]byte, error) + func (o Optional[T]) MustGet() T + func (o Optional[T]) Or(other Optional[T]) Optional[T] + func (o Optional[T]) OrElse(fallback T) T + func (o Optional[T]) OrElseGet(fn func() T) T + func (o Optional[T]) OrErr(err error) (T, error) + func (o Optional[T]) Ptr() *T + func (o Optional[T]) Seq() iter.Seq[T] + func (o Optional[T]) String() string + type Pair struct + First A + Second B + type Track struct + func Groove[T0, T1 any](f Fe[T0, T1]) Track[T0, T1] + func (t Track[T0, T1]) Jam[T2 any](g Fe[T1, T2]) Track[T0, T2] + func (t Track[T0, T1]) Play(t0 T0) (T1, error)
Go to main page