Skip to content

Commit 5b570de

Browse files
Update (*valueReader).ReadTimestamp() to support bVR + streaming
1 parent 83a47d5 commit 5b570de

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

bson/value_reader.go

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -781,17 +781,17 @@ func (vr *valueReader) ReadSymbol() (string, error) {
781781

782782
// ReadTimestamp reads a BSON Timestamp value, advancing the reader to the end
783783
// of the Timestamp value.
784-
func (vr *valueReader) ReadTimestamp() (t uint32, i uint32, err error) {
784+
func (vr *valueReader) ReadTimestamp() (uint32, uint32, error) {
785785
if err := vr.ensureElementValue(TypeTimestamp, 0, "ReadTimestamp"); err != nil {
786786
return 0, 0, err
787787
}
788788

789-
i, err = vr.readu32()
789+
i, err := vr.readu32()
790790
if err != nil {
791791
return 0, 0, err
792792
}
793793

794-
t, err = vr.readu32()
794+
t, err := vr.readu32()
795795
if err != nil {
796796
return 0, 0, err
797797
}
@@ -803,6 +803,7 @@ func (vr *valueReader) ReadTimestamp() (t uint32, i uint32, err error) {
803803
}
804804

805805
// ReadUndefined reads a BSON Undefined value, advancing the reader position
806+
806807
// to the end of the Undefined value.
807808
func (vr *valueReader) ReadUndefined() error {
808809
if err := vr.ensureElementValue(TypeUndefined, 0, "ReadUndefined"); err != nil {

0 commit comments

Comments
 (0)