From f05d6a0e83d2fa39fc4534ca350d6f66b95f325b Mon Sep 17 00:00:00 2001 From: Johan Walles Date: Mon, 18 Mar 2024 18:06:10 +0100 Subject: [PATCH] Only report first byte on read success --- m/reader.go | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/m/reader.go b/m/reader.go index ff6912d..40c09c2 100644 --- a/m/reader.go +++ b/m/reader.go @@ -126,13 +126,14 @@ func (reader *Reader) readStream(stream io.Reader, originalFileName *string, onD for keepReadingLine { lineBytes, keepReadingLine, err = bufioReader.ReadLine() - // Async write, it might already have been written to - select { - case reader.doneWaitingForFirstByte <- true: - default: - } - if err == nil { + // Async write, we probably already wrote to it during the last + // iteration + select { + case reader.doneWaitingForFirstByte <- true: + default: + } + completeLine = append(completeLine, lineBytes...) continue }