Skip to content

Commit cefd0b5

Browse files
authored
Forward io.EOF in read until newline (#3)
Forward io.EOF when reading until newline.
1 parent 85fba07 commit cefd0b5

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

simdjson.go

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -148,12 +148,14 @@ func ParseNDStream(r io.Reader, res chan<- Stream, reuse <-chan *ParsedJson) {
148148
tmp = tmp[:n]
149149
// Read until Newline
150150
if err != io.EOF {
151-
b, err := buf.ReadBytes('\n')
152-
if err != nil && err != io.EOF {
153-
queueError(queue, err)
151+
b, err2 := buf.ReadBytes('\n')
152+
if err2 != nil && err2 != io.EOF {
153+
queueError(queue, err2)
154154
return
155155
}
156156
tmp = append(tmp, b...)
157+
// Forward io.EOF
158+
err = err2
157159
}
158160

159161
trimmed := bytes.TrimSpace(tmp)

0 commit comments

Comments
 (0)