Skip to content

Commit 296ff25

Browse files
Update (*valueReader).read(i32|u32|i64|u64)() to support bVR + streaming
1 parent 0ba5775 commit 296ff25

File tree

1 file changed

+8
-12
lines changed

1 file changed

+8
-12
lines changed

bson/value_reader.go

Lines changed: 8 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -939,41 +939,37 @@ func (vr *valueReader) readLength() (int32, error) {
939939
}
940940

941941
func (vr *valueReader) readi32() (int32, error) {
942-
var buf [4]byte
943-
err := vr.read(buf[:])
942+
raw, err := readBytes(vr.src, 4)
944943
if err != nil {
945944
return 0, err
946945
}
947946

948-
return int32(binary.LittleEndian.Uint32(buf[:])), nil
947+
return int32(binary.LittleEndian.Uint32(raw)), nil
949948
}
950949

951950
func (vr *valueReader) readu32() (uint32, error) {
952-
var buf [4]byte
953-
err := vr.read(buf[:])
951+
raw, err := readBytes(vr.src, 4)
954952
if err != nil {
955953
return 0, err
956954
}
957955

958-
return binary.LittleEndian.Uint32(buf[:]), nil
956+
return binary.LittleEndian.Uint32(raw), nil
959957
}
960958

961959
func (vr *valueReader) readi64() (int64, error) {
962-
var buf [8]byte
963-
err := vr.read(buf[:])
960+
raw, err := readBytes(vr.src, 8)
964961
if err != nil {
965962
return 0, err
966963
}
967964

968-
return int64(binary.LittleEndian.Uint64(buf[:])), nil
965+
return int64(binary.LittleEndian.Uint64(raw)), nil
969966
}
970967

971968
func (vr *valueReader) readu64() (uint64, error) {
972-
var buf [8]byte
973-
err := vr.read(buf[:])
969+
raw, err := readBytes(vr.src, 8)
974970
if err != nil {
975971
return 0, err
976972
}
977973

978-
return binary.LittleEndian.Uint64(buf[:]), nil
974+
return binary.LittleEndian.Uint64(raw), nil
979975
}

0 commit comments

Comments
 (0)