Function FindFiles

script.go:95–112

FindFiles creates a pipe listing all the files in the directory dir and its subdirectories recursively, one per line, like Unix find(1). Errors are ignored unless no files are found (in which case the pipe's error status will be set to the last error encountered). Each line of the output consists o

(dir string)

//	test/1.txt
//	test/2.txt
func FindFiles(dir string) *Pipe {
	var paths []string
	var innerErr error
	fs.WalkDir(os.DirFS(dir), ".", func(path string, d fs.DirEntry, err error) error {
		if err != nil {
			innerErr = err
			return fs.SkipDir
		}
		if !d.IsDir() {
			paths = append(paths, filepath.Join(dir, path))
		}
		return nil
	})
	if innerErr != nil && len(paths) == 0 {
		return NewPipe().WithError(innerErr)
	}
	return Slice(paths)
}

// Get creates a pipe that makes an HTTP GET request to url, and produces the
// response. See [Pipe.Do] for how the HTTP response status is interpreted.