Clarify logic

Author: qingyang-hu

internal/integration/csot_prose_test.go

@@ -227,10 +227,8 @@ func TestCSOTProse(t *testing.T) {
 			SetTimeout(2 * time.Second).
 			SetMonitor(cm).
 			ApplyURI(mtest.ClusterURI())
-		integtest.AddTestServerAPIVersion(cliOptions)
-		cli, err := mongo.Connect(cliOptions)
-		require.NoError(mt, err, "Connect error: %v", err)
-		_, err = cli.BulkWrite(context.Background(), writes)
+		mt.ResetClient(cliOptions)
+		_, err = mt.Client.BulkWrite(context.Background(), writes)
 		assert.ErrorIs(mt, err, context.DeadlineExceeded, "expected a timeout error, got: %v", err)
 		assert.Equal(mt, 2, cnt, "expected bulkWrite calls: %d, got: %d", 2, cnt)
 	})

mongo/client_bulk_write.go

@@ -7,7 +7,6 @@
 package mongo
 
 import (
-	"bytes"
 	"context"
 	"errors"
 	"fmt"
@@ -427,9 +426,7 @@ func (mb *modelBatches) processResponse(ctx context.Context, resp bsoncore.Docum
 		Code      int32
 		Errmsg    string
 	}
-	dec := bson.NewDecoder(bson.NewDocumentReader(bytes.NewReader(resp)))
-	dec.SetRegistry(mb.client.registry)
-	err := dec.Decode(&res)
+	err := bson.Unmarshal(resp, &res)
 	if err != nil {
 		return err
 	}