Versions in this module Expand all Collapse all v0 v0.0.3 May 31, 2024 Changes in this version + func WalkDir[T any](ctx context.Context, fsys fs.FS, root string, slow bool, onFile onFile[T], ...) error + type Pipeline struct + func NewPipeline[T, U any](numWorkers int, progress bool, items []T, fn1 onItem[T, U], fn2 onResult[U]) Pipeline[T, U] + func (p *Pipeline[T, U]) Do(ctx context.Context) error