Forward err also on io.EOF error

protocol/internal/testnative/native

@@ -1,4 +1,4 @@
 #!/bin/bash
 dir=$(dirname $0)
 cd $dir
-exec go run ./main.go $@
+exec go run ./main.go $@

protocol/jsonlines/decoder.go

@@ -39,25 +39,11 @@ func NewDecoder(r io.Reader) Decoder {
 	return &decoder{r: lr}
 }
 
-func (d *decoder) readLine() (line []byte, err error) {
-	line, err = d.r.ReadBytes('\n')
-
-	switch(err) {
-	case nil:
-		fallthrough
-	case io.EOF:
-		return line, nil
-	default:
-		// ReadBytes will return all content read until the error
-		return line, err
-	}
-}
-
 // Decode decodes the next line in the reader.
 // It does not check JSON for well-formedness before decoding, so in case of
 // error, the structure might be half-filled.
 func (d *decoder) Decode(v interface{}) error {
-	line, err := d.readLine()
+	line, err := d.r.ReadBytes('\n')
 	if err != nil {
 		return err
 	}

protocol/jsonlines/decoder_test.go

@@ -14,7 +14,8 @@ func TestDecoder(t *testing.T) {
 
 	input := `{"example":1}
 	{"example":2}
-	{"example":3}`
+	{"example":3}
+	`
 	d := NewDecoder(strings.NewReader(input))
 	out := map[string]int{}
 
@@ -39,7 +40,8 @@ func TestDecoderWithBufferedReader(t *testing.T) {
 
 	input := `{"example":1}
 	{"example":2}
-	{"example":3}`
+	{"example":3}
+	`
 	d := NewDecoder(bufio.NewReader(strings.NewReader(input)))
 	out := map[string]int{}