imp

shamaton · Mar 14, 2024 · b73d904 · b73d904
1 parent 4bda28d
commit b73d904
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/ext/decoder_stream.go b/ext/decoder_stream.go
@@ -50,7 +50,8 @@ func (d *DecoderStreamCommon) ReadSizeN(r io.Reader, buf *common.Buffer, n int)
 	if len(buf.Data) <= n {
 		b = buf.Data[:n]
 	} else {
-		b = make([]byte, n)
+		buf.Data = append(buf.Data, make([]byte, n-len(buf.Data))...)
+		b = buf.Data
 	}
 	if _, err := r.Read(b); err != nil {
 		return emptyBytes, err

diff --git a/internal/stream/decoding/read.go b/internal/stream/decoding/read.go
@@ -41,7 +41,7 @@ func (d *decoder) readSizeN(n int) ([]byte, error) {
 		b = d.buf.Data[:n]
 	} else {
 		d.buf.Data = append(d.buf.Data, make([]byte, n-len(d.buf.Data))...)
-		b = make([]byte, n)
+		b = d.buf.Data
 	}
 	if _, err := d.r.Read(b); err != nil {
 		return emptyBytes, err