func()

in internal/preprocess/preprocessing.go [63:72]


func (r *Runner) run(ctx context.Context) error {
	defer close(r.out)
	for entry := range r.in {
		if err := r.processEntry(ctx, entry); err != nil {
			continue
		}
		r.out <- entry
	}
	return nil
}