fix: updated reader headers

jeroenrinzema · Aug 24, 2024 · 3465ec7 · 3465ec7
1 parent f7957a3
commit 3465ec7
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/pkg/buffer/reader.go b/pkg/buffer/reader.go
@@ -54,7 +54,6 @@ func NewReader(logger *slog.Logger, reader io.Reader, bufferSize int) *Reader {
 func (reader *Reader) reset(size int) {
 	if reader.Msg != nil {
 		reader.Msg = reader.Msg[len(reader.Msg):]
-		return
 	}
 
 	if cap(reader.Msg) >= size {
@@ -153,7 +152,7 @@ func (reader *Reader) ReadUntypedMsg() (int, error) {
 
 	reader.reset(size)
 	n, err := io.ReadFull(reader.Buffer, reader.Msg)
-	return n, err
+	return len(reader.header) + n, err
 }
 
 // GetString reads a null-terminated string.