From 1651987399aac8d3b1e83f32020f2b3c6a0d2a51 Mon Sep 17 00:00:00 2001 From: Leon Mika Date: Mon, 24 Apr 2023 05:07:33 +0000 Subject: [PATCH] Changed signature of SubPipe --- subpipe.go | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/subpipe.go b/subpipe.go index 738e02e..6f69b0d 100644 --- a/subpipe.go +++ b/subpipe.go @@ -2,8 +2,9 @@ package scriptx import ( "bufio" - "github.com/bitfield/script" "io" + + "github.com/bitfield/script" ) func eachLine(r io.Reader, fn func(line string) error) error { @@ -16,11 +17,11 @@ func eachLine(r io.Reader, fn func(line string) error) error { return scanner.Err() } -func SubPipe(fn func(src string) *script.Pipe) func(r io.Reader, w io.Writer) error { +func SubPipe(fn func(src *script.Pipe) *script.Pipe) func(r io.Reader, w io.Writer) error { return func(r io.Reader, w io.Writer) error { scanner := bufio.NewScanner(r) for scanner.Scan() { - bts, err := fn(scanner.Text()).Bytes() + bts, err := fn(script.Echo(scanner.Text())).Bytes() if err != nil { return err } @@ -30,4 +31,4 @@ func SubPipe(fn func(src string) *script.Pipe) func(r io.Reader, w io.Writer) er } return scanner.Err() } -} \ No newline at end of file +}