google-gax - npm Package Compare versions

Comparing version 4.3.3 to 4.3.4

build/src/streamingCalls/streaming.js

@@ -75,3 +75,3 @@ "use strict";
             if (resumptionRetryArgument !== undefined) {
-                retryArgument = retry.getResumptionRequestFn(retryArgument);
+                retryArgument = resumptionRetryArgument;
             }
@@ -314,2 +314,3 @@ }
                     else {
+                        this.retries++;
                         retryStream = this.retry(stream, retry);
@@ -316,0 +317,0 @@ this.stream = retryStream;

build/src/streamingRetryRequest.js

@@ -88,4 +88,7 @@ "use strict";
         delayStream.pipe(retryStream);
-        requestStream.on('error', (err) => {
-            retryStream.destroy(err);
+        requestStream.on('error', () => {
+            // retryStream must be destroyed here for the stream handoff part of retries to function properly
+            // but the error event should not be passed - if it emits as part of .destroy()
+            // it will bubble up early to the caller
+            retryStream.destroy();
         });
@@ -92,0 +95,0 @@ }

package.json

 {
   "name": "google-gax",
-  "version": "4.3.3",
+  "version": "4.3.4",
   "description": "Google API Extensions",
@@ -24,3 +24,3 @@ "main": "build/src/index.js",
     "uuid": "^9.0.1",
-    "protobufjs": "7.2.6"
+    "protobufjs": "7.3.0"
   },
@@ -27,0 +27,0 @@ "devDependencies": {

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

3286426

increased by0.03%

Lines of code

27342

increased by0.01%

Dependency changes

• + Addedprotobufjs@7.3.0(transitive)

• - Removedprotobufjs@7.2.6(transitive)

• Updatedprotobufjs@7.3.0