Versions in this module Expand all Collapse all v0 v0.44.0 Aug 25, 2023 v0.0.1 Oct 9, 2023 Changes in this version + func WalkDir(ctx context.Context, fsys fs.FS, root string, slow bool, onFile onFile[T], ...) error + type Pipeline struct + func NewPipeline(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
Go to main page