para

Documentation

Index

• func Batch[T any](ctx context.Context, seq iter.Seq[T], ...) error
• func Fanout[V any](seq iter.Seq[V], fn func(value V))
• func Gather(fns ...func() error) error
• func MapErr[In any, Out any](ctx context.Context, seq []In, ...) ([]Out, error)

Functions

func Batch

func Batch[T any](ctx context.Context, seq iter.Seq[T], work func(ctx context.Context, ii int, v T) error) error

Batch processes the sequence concurrently. Any error cancels the entire batch. No results are generated. This is helpful for a fanout of side-effects.

func Fanout

func Fanout[V any](seq iter.Seq[V], fn func(value V))

Fanout processes a sequence concurrently.

func Gather

func Gather(fns ...func() error) error

Gather processes a batch of heterogenous operations.

func MapErr

func MapErr[In any, Out any](ctx context.Context, seq []In, work func(ctx context.Context, ii int, v In) (Out, error)) ([]Out, error)

MapErr processes the sequence concurrently, transforming [In] to [Out]. Any error cancels the entire batch. This is helpful for a fanout of fallible transformations.