Function LinewiseFunction

internal/pipe/linewise.go:48–59

LinewiseFunction returns a function-based `Stage`. The input will be split into LF-terminated lines and passed to the function one line at a time (without the LF). The function may emit output to its `stdout` argument. See the definition of `LinewiseStageFunc` for more information. Note that the st

(name string, f LinewiseStageFunc)

// `NewScannerFunc` as argument, or use `Function()` directly with
// your own `StageFunc`.
func LinewiseFunction(name string, f LinewiseStageFunc) Stage {
	return ScannerFunction(
		name,
		func(r io.Reader) (Scanner, error) {
			scanner := bufio.NewScanner(r)
			// Split based on strict LF (we don't accept CRLF):
			scanner.Split(ScanLFTerminatedLines)
			return scanner, nil
		},
		f,
	)
}

// ScanLFTerminatedLines is a `bufio.SplitFunc` that splits its input
// into lines at LF characters (not treating CR specially).