Update (*valueReader).peekLength() to support bVR + streaming

prestonvasquez · prestonvasquez · commit f62a9dec1827 · 2025-07-11T13:02:45.000-06:00
diff --git a/bson/value_reader.go b/bson/value_reader.go
@@ -927,11 +927,10 @@ func (vr *valueReader) readString() (string, error) {
 }
 
 func (vr *valueReader) peekLength() (int32, error) {
-	buf, err := vr.r.Peek(4)
+	buf, err := vr.src.peek(4)
 	if err != nil {
 		return 0, err
 	}
-
 	return int32(binary.LittleEndian.Uint32(buf)), nil
 }
 

Original file line number	Diff line number	Diff line change
`@@ -927,11 +927,10 @@ func (vr *valueReader) readString() (string, error) {`
`927`	`927`	`}`
`928`	`928`
`929`	`929`	`func (vr *valueReader) peekLength() (int32, error) {`
`930`		`- buf, err := vr.r.Peek(4)`
	`930`	`+ buf, err := vr.src.peek(4)`
`931`	`931`	`if err != nil {`
`932`	`932`	`return 0, err`
`933`	`933`	`}`
`934`		`-`
`935`	`934`	`return int32(binary.LittleEndian.Uint32(buf)), nil`
`936`	`935`	`}`
`937`	`936`