parallel

Feb 14, 2022

Changes in this version

+ func Do(parallelism int, n int, f func(i int))

+ func DoContext(ctx context.Context, parallelism int, n int, ...) error

+ func Map(parallelism int, in []T, f func(in T) U) []U

+ func MapContext(ctx context.Context, parallelism int, in []T, ...) ([]U, error)

+ func MapIterator(iter iterator.Iterator[T], parallelism int, bufferSize int, f func(T) U) iterator.Iterator[U]

+ func MapStream(ctx context.Context, s stream.Stream[T], parallelism int, bufferSize int, ...) stream.Stream[U]