Versions in this module Expand all Collapse all v0 v0.0.2 May 24, 2023 Changes in this version + func Call(ctx context.Context, fn func() error) context.Context v0.0.1 May 24, 2023 Changes in this version + func Map(tree *Tree, values []U, fn func(context.Context, U) (T, error)) ([]T, error) + func NoJitter() time.Duration + func Schedule(tree *Tree, fn func(context.Context) (time.Duration, error)) error + type Channel struct + func ToChannel(ctx context.Context, dest chan<- T, options ...Option) (*Channel[T], context.Context) + func (v *Channel[T]) Go(fn func(context.Context) (T, error)) + func (v *Channel[T]) Sub(fn func(context.Context, *Channel[T]) error) + func (v *Channel[T]) Wait() error + type Option func(*Tree) + func WithConcurrencyLimit(n int) Option + func WithJitter(fn func() time.Duration) Option + type Tree struct + func New(ctx context.Context, options ...Option) (*Tree, context.Context) + func (g *Tree) Go(fn func(context.Context) error) + func (g *Tree) Link(waiter Waiter) + func (g *Tree) Sub(fn func(context.Context, *Tree) error, options ...Option) + func (g *Tree) Wait() error + type Waiter interface + Wait func() error
Go to main page