Versions in this module Expand all Collapse all v7 v7.0.4 Jan 30, 2023 v7.0.2 Jan 30, 2023 v7.0.1 Jan 30, 2023 v7.0.0 Jan 30, 2023 Changes in this version + type IterResult struct + Err error + Finished bool + Item T + func CollectAll(ctx context.Context, it TryNextor[T]) IterResult[[]T] + func CollectMany(ctx context.Context, it TryNextor[T], n uint) IterResult[[]T] + func Done() IterResult[T] + func DoneBy(r IterResult[O]) IterResult[T] + func Emit(t T) IterResult[T] + func Throw(err error) IterResult[T] + func (r IterResult[T]) FinishedOrError() bool + func (r IterResult[T]) String() string + type TransformConfig func(*chunkMappingCfg) + func WithChunkSize(n uint) TransformConfig + func WithConcurrency(n uint) TransformConfig + type TryNextor interface + TryNext func(ctx context.Context) IterResult[T] + func ConcatAll(items ...TryNextor[T]) TryNextor[T] + func Fail(err error) TryNextor[T] + func FilterOut(it TryNextor[T], f func(T) bool) TryNextor[T] + func FlatMap(it TryNextor[T], mapper func(T) TryNextor[R]) TryNextor[R] + func FromSlice(s []T) TryNextor[T] + func Map(it TryNextor[T], mapper func(T) R) TryNextor[R] + func OfRange(begin, end T) TryNextor[T] + func TakeFirst(inner TryNextor[T], n uint) TryNextor[T] + func Tap(i TryNextor[T], with func(T)) TryNextor[T] + func Transform(it TryNextor[T], with func(context.Context, T) (R, error), ...) TryNextor[R]
Go to main page