Method Filter

script.go:536–551

Filter sends the contents of the pipe to the function filter and produces the result. filter takes an [io.Reader] to read its input from and an [io.Writer] to write its output to, and returns an error, which will be set on the pipe. filter runs concurrently, so its goroutine will not exit until the

(filter func(io.Reader, io.Writer) error)

// been fully read. Use [Pipe.Wait] to wait for all concurrent filters to
// complete.
func (p *Pipe) Filter(filter func(io.Reader, io.Writer) error) *Pipe {
	if p.Error() != nil {
		return p
	}
	pr, pw := io.Pipe()
	origReader := p.Reader
	p = p.WithReader(pr)
	go func() {
		defer pw.Close()
		err := filter(origReader, pw)
		if err != nil {
			p.SetError(err)
		}
	}()
	return p
}

// FilterLine sends the contents of the pipe to the function filter, a line at
// a time, and produces the result. filter takes each line as a string and