feat(scanner): fix Scan function

humanlogio · Nov 6, 2024 · ec884b0 · ec884b0
1 parent 1a3ae08
commit ec884b0
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/scanner.go b/scanner.go
@@ -32,6 +32,7 @@ func Scan(ctx context.Context, src io.Reader, sink sink.Sink, opts *HandlerOptio
 	data := new(typesv1.StructuredLogEvent)
 	ev.Structured = data
 
+	skipNextScan := false
 	for {
 		if !in.Scan() {
 			err := in.Err()
@@ -42,11 +43,15 @@ func Scan(ctx context.Context, src io.Reader, sink sink.Sink, opts *HandlerOptio
 				in = bufio.NewScanner(src)
 				in.Buffer(make([]byte, 0, maxBufferSize), maxBufferSize)
 				in.Split(bufio.ScanLines)
-				in.Scan()
+				skipNextScan = true
 				continue
 			}
 			break
 		}
+		if skipNextScan {
+			skipNextScan = false
+			continue
+		}
 
 		line++
 		lineData := in.Bytes()