xsync

Nov 10, 2023

Changes in this version

+ type ParallelMapper interface

+ Errors func() []error

+ Map func([]Input) error

+ Results func() []Output

+ func NewParallelMapper[Input, Output any](worker func(Input) (Output, error), options ...ParallelOption) ParallelMapper[Input, Output]

+ type ParallelOption func(*parallelMapperOptions)

+ func WithMaxWait(maxWait time.Duration) ParallelOption

+ func WithMaxWorkers(maxWorkers int) ParallelOption