mongodb - npm Package Compare versions

Comparing version 6.9.0-dev.20240927.sha.681ddd8d to 6.9.0-dev.20240928.sha.3f9d2437

lib/cmap/connection.js

@@ -69,2 +69,3 @@ "use strict";
         this.socket.on('timeout', this.onTimeout.bind(this));
+        this.messageStream.pause();
     }
@@ -367,2 +368,3 @@ get hello() {
             this.dataEvents = (0, on_data_1.onData)(this.messageStream);
+            this.messageStream.resume();
             for await (const message of this.dataEvents) {
@@ -378,2 +380,3 @@ const response = await (0, compression_1.decompressResponse)(message);
             this.dataEvents = null;
+            this.messageStream.pause();
             this.throwIfAborted();
@@ -380,0 +383,0 @@ }

package.json

 {
   "name": "mongodb",
-  "version": "6.9.0-dev.20240927.sha.681ddd8d",
+  "version": "6.9.0-dev.20240928.sha.3f9d2437",
   "description": "The official MongoDB driver for Node.js",
@@ -5,0 +5,0 @@ "main": "lib/index.js",

src/cmap/connection.ts

@@ -240,2 +240,4 @@ import { type DeserializeOptions } from 'bson';
     this.socket.on('timeout', this.onTimeout.bind(this));
+
+    this.messageStream.pause();
   }
@@ -655,2 +657,3 @@
       this.dataEvents = onData(this.messageStream);
+      this.messageStream.resume();
       for await (const message of this.dataEvents) {
@@ -666,2 +669,3 @@ const response = await decompressResponse(message);
       this.dataEvents = null;
+      this.messageStream.pause();
       this.throwIfAborted();
@@ -668,0 +672,0 @@ }

No alert changes

Improved metrics

Total package byte prevSize

3465307

increased by0.01%

Lines of code

72489

increased by0.01%

No dependency changes