loop

Jul 2, 2024

Changes in this version

+ func MapResolv[K comparable, V, VR any](next func() (K, V, bool, error), resolver func(bool, K, VR, V) VR) (map[K]VR, error)

+ func Map[K comparable, V any](next func() (K, V, bool, error)) (map[K]V, error)

+ func Slice[K, V, T any](next func() (K, V, bool, error), converter func(K, V) T) ([]T, error)

Jun 16, 2024

Changes in this version

+ func ReduceOK[K, V any](next func() (K, V, bool, error), merge func(K, K, V, V) (K, V)) (rk K, rv V, ok bool, err error)

+ func ReduceeOK[K, V any](next func() (K, V, bool, error), merge func(K, K, V, V) (K, V, error)) (rk K, rv V, ok bool, err error)

type Loop

+ func (next Loop[K, V]) ReduceOK(merge func(K, K, V, V) (K, V)) (K, V, bool, error)

+ func (next Loop[K, V]) ReduceeOK(merge func(K, K, V, V) (K, V, error)) (K, V, bool, error)

Mar 31, 2024

Changes in this version

+ func Track[I, T any](next func() (I, T, bool, error), consumer func(I, T) error) error

+ type Loop func() (K, V, bool, error)

+ func Crank[K, V any](next func() (K, V, bool, error)) (n Loop[K, V], k K, v V, ok bool, err error)

+ func (next Loop[K, V]) Crank() (Loop[K, V], K, V, bool, error)

+ func (next Loop[K, V]) Filt(filter func(K, V) (bool, error)) Loop[K, V]

+ func (next Loop[K, V]) Filter(filter func(K, V) bool) Loop[K, V]

+ func (next Loop[K, V]) First(predicate func(K, V) bool) (K, V, bool, error)

+ func (next Loop[K, V]) HasAny(predicate func(K, V) bool) (bool, error)

+ func (next Loop[K, V]) Reduce(merge func(K, K, V, V) (K, V)) (K, V, error)

+ func (next Loop[K, V]) Reducee(merge func(K, K, V, V) (K, V, error)) (K, V, error)

+ func (next Loop[K, V]) Track(consumer func(K, V) error) error

Jun 11, 2023

Changes in this version

type ConvertIter

+ func (i ConvertIter[K, V, K2, V2]) Start() (ConvertIter[K, V, K2, V2], K2, V2, bool, error)

type FiltIter

+ func (f FiltIter[K, V]) Start() (FiltIter[K, V], K, V, bool, error)

May 26, 2023

Changes in this version

+ type FiltIter struct

+ func (f FiltIter[K, V]) Next() (key K, value V, ok bool, err error)

+ func (f FiltIter[K, V]) Track(traker func(key K, value V) error) error

May 17, 2023

Changes in this version

+ func First(next func() (K, V, bool, error), predicate func(K, V) bool) (K, V, bool, error)

+ func Firstt(next func() (K, V, bool, error), predicate func(K, V) (bool, error)) (K, V, bool, error)

+ func HasAnyy(next func() (K, V, bool, error), predicate func(K, V) (bool, error)) (bool, error)

+ func Reducee(next func() (K, V, bool, error), merge func(K, K, V, V) (K, V, error)) (rk K, rv V, err error)

+ type Looper interface

+ Loop func() I

May 5, 2023

Changes in this version

+ func From(next func() (K, V, bool)) func() (K, V, bool, error)

+ func Group(next func() (K, V, bool, error)) (map[K][]V, error)

+ func HasAny(next func() (K, V, bool, error), predicate func(K, V) (bool, error)) (bool, error)

+ func New(source S, hasNext func(S) bool, getNext func(S) (K, V, error)) func() (K, V, bool, error)

+ func Reduce(next func() (K, V, bool, error), merge func(K, V, K, V) (K, V, error)) (rk K, rv V, err error)

+ func To(next func() (K, V, bool, error), errConsumer func(error)) func() (K, V, bool)

+ func ToMap(next func() (K, V, bool, error)) (map[K]V, error)

+ func ToMapResolv(next func() (K, V, bool, error), resolver func(bool, K, VR, V) VR) (map[K]VR, error)

+ func ToSlice(next func() (K, V, bool, error)) ([]c.KV[K, V], error)

+ type ConvertIter struct

+ func Conv(next func() (K, V, bool, error), converter func(K, V) (KOUT, VOUT, error)) ConvertIter[K, V, KOUT, VOUT]

+ func Convert(next func() (K, V, bool, error), converter func(K, V) (KOUT, VOUT)) ConvertIter[K, V, KOUT, VOUT]

+ func (i ConvertIter[K, V, K2, V2]) Next() (k2 K2, v2 V2, ok bool, err error)

+ func (i ConvertIter[K, V, K2, V2]) Track(traker func(key K2, value V2) error) error

+ type FiltKV struct

+ func Filt(next func() (K, V, bool, error), filter func(K, V) (bool, error)) FiltKV[K, V]

+ func Filter(next func() (K, V, bool, error), filter func(K, V) bool) FiltKV[K, V]

+ func (f FiltKV[K, V]) Next() (key K, value V, ok bool, err error)

+ func (f FiltKV[K, V]) Track(traker func(key K, value V) error) error