Versions in this module Expand all Collapse all v0 v0.1.1 Jun 24, 2026 v0.1.0 Apr 8, 2026 Changes in this version + const ExecutorDefault + func Collect2[From1, From2, To any](ctx *context.Context, executorName string, iterator iter.Seq2[From1, From2], ...) error + func CollectMap[From comparable, To any](ctx *context.Context, executorName string, values iter.Seq[From], ...) error + func CollectSlice[From, To any](ctx *context.Context, executorName string, values iter.Seq[From], ...) error + func Collect[From, To any](ctx *context.Context, executorName string, iterator iter.Seq[From], ...) error + func HasContextExecutor(ctx context.Context, name string) bool + func ParallelWriter(ctx context.Context, executorName string, writers ...io.Writer) io.Writer + func SetContextExecutor(ctx context.Context, name string, executor Executor) context.Context + func ToIndexSeq[T any](values []T) iter.Seq2[int, T] + func ToSeq2[K comparable, V any](values map[K]V) iter.Seq2[K, V] + func ToSeq[T any](values []T) iter.Seq[T] + func ToSlice[T any](values iter.Seq[T]) (everything []T) + type Appender interface + Append func(value T) + type ChildExecutor interface + ChildExecutor func() Executor + type Collection interface + Contains func(value T) bool + Len func() int + Remove func(value T) + type Executor interface + Go func(func()) + Wait func(context.Context) + func ContextExecutor(ctx *context.Context, name string) Executor + func NewExecutor(maxConcurrency int) Executor + type Iterable interface + Seq func(fn func(value T) bool) + type List struct + func (s *List[T]) Append(value T) + func (s *List[T]) Clear() + func (s *List[T]) Contains(value T) bool + func (s *List[T]) Dequeue() (value T, ok bool) + func (s *List[T]) Enqueue(value T) + func (s *List[T]) Len() int + func (s *List[T]) Peek() (value T, ok bool) + func (s *List[T]) Pop() (value T, ok bool) + func (s *List[T]) Push(value T) + func (s *List[T]) Remove(value T) + func (s *List[T]) RemoveAll(values iter.Seq[T]) + func (s *List[T]) Seq(fn func(value T) bool) + func (s *List[T]) Update(updater func(values []T) []T) + func (s *List[T]) Values() []T + type Lockable interface + Lock func() (unlock UnlockFunc) + RLock func() (unlock UnlockFunc) + type Locking struct + func (l *Locking) IsExclusiveLock(unlockFunc UnlockFunc) (exclusive bool) + func (l *Locking) Lock() (unlock UnlockFunc) + func (l *Locking) RLock() (unlock UnlockFunc) + type PanicError struct + Stack string + Value any + func (p PanicError) Error() string + func (p PanicError) Unwrap() error + type Provider interface + Get func() T + type Queue interface + Dequeue func() (value T, ok bool) + Enqueue func(value T) + type Stack interface + Peek func() (value T, ok bool) + Pop func() (value T, ok bool) + Push func(value T) + type UnlockFunc func()
Go to main page