processor

Sep 22, 2025

Changes in this version

type Processor

+ func (p *Processor) DoWithParallel2(works []func(ctx context.Context) Result, numWorkers int, ...)

+ func (p *Processor) DoWithRepeat2(work func(ctx context.Context) Result, rate time.Duration, until time.Time, ...)

Jul 17, 2025

Changes in this version

+ func OrDone[T any](ctx context.Context, works <-chan T) <-chan T

+ func SpeedLimit(ctx context.Context, works <-chan Work, speedLimit time.Duration) <-chan Work

+ type Processor struct

+ func NewProcessor(ctx context.Context) *Processor

+ func (p *Processor) DoWithParallel(works <-chan Work, numWorkers int) Results

+ func (p *Processor) DoWithRate(works <-chan Work, rate time.Duration) Results

+ func (p *Processor) DoWithRepeat(work Work, rate time.Duration, until time.Time) Results

+ type Result struct

+ Err error

+ Val any

+ func NewResult[R any](val R, err error) Result

+ type Results <-chan Result

+ func CollectResults(ctx context.Context, rs ...Results) Results

+ func (rs Results) HandleResults(f func(result Result))

+ type Work struct

+ Do func(ctx context.Context) Result