Function seqFunction

internal/pipe/pipeline_test.go:429–442

(n int)

}

func seqFunction(n int) pipe.Stage {
	return pipe.Function(
		"seq",
		func(_ context.Context, _ pipe.Env, _ io.Reader, stdout io.Writer) error {
			for i := 1; i <= n; i++ {
				_, err := fmt.Fprintf(stdout, "%d\n", i)
				if err != nil {
					return err
				}
			}
			return nil
		},
	)
}

func TestPipelineWithLinewiseFunction(t *testing.T) {
	t.Parallel()