From 3c0e1b5e8c5df3b8b485048e3dd4c05c817ecc9d Mon Sep 17 00:00:00 2001
From: Masaaki Goshima <goccy54@gmail.com>
Date: Sun, 6 Jun 2021 10:52:55 +0900
Subject: [PATCH] Fix stream buffer length

---
 internal/decoder/stream.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/internal/decoder/stream.go b/internal/decoder/stream.go
index b473244..9171107 100644
--- a/internal/decoder/stream.go
+++ b/internal/decoder/stream.go
@@ -198,6 +198,7 @@ func (s *Stream) readBuf() []byte {
 		}
 		remainNotNulCharNum++
 	}
+	s.length = s.cursor + remainNotNulCharNum
 	return s.buf[s.cursor+remainNotNulCharNum:]
 }
 
@@ -209,7 +210,7 @@ func (s *Stream) read() bool {
 	last := len(buf) - 1
 	buf[last] = nul
 	n, err := s.r.Read(buf[:last])
-	s.length = s.cursor + int64(n)
+	s.length += int64(n)
 	if n == last {
 		s.filledBuffer = true
 	} else {