bugfix: fix stream parsing issue

tair-opensource · Jan 3, 2024 · 0d78f8e · 0d78f8e
1 parent 10068d3
commit 0d78f8e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/internal/rdb/types/stream.go b/internal/rdb/types/stream.go
@@ -141,7 +141,7 @@ func (o *StreamObject) readStream(rd io.Reader, masterKey string, typeByte byte)
 	 * in case of XDEL lastid. */
 	o.cmds = append(o.cmds, []string{"xsetid", masterKey, lastid})
 
-	if typeByte == rdbTypeStreamListpacks2 {
+	if typeByte >= rdbTypeStreamListpacks2 {
 		/* Load the first entry ID. */
 		_ = structure.ReadLength(rd) // first_ms
 		_ = structure.ReadLength(rd) // first_seq