@grpc/grpc-js - npm Package Compare versions

Comparing version 1.9.12 to 1.9.13

build/src/internal-channel.js

@@ -166,3 +166,5 @@ "use strict";
                 this.pickQueue = [];
-                this.callRefTimerUnref();
+                if (queueCopy.length > 0) {
+                    this.callRefTimerUnref();
+                }
                 for (const call of queueCopy) {
@@ -205,7 +207,8 @@ call.doPick();
                 this.configSelectionQueue = [];
-                this.callRefTimerUnref();
+                if (localQueue.length > 0) {
+                    this.callRefTimerUnref();
+                }
                 for (const call of localQueue) {
                     call.getConfig();
                 }
-                this.configSelectionQueue = [];
             });
@@ -228,3 +231,5 @@ }, status => {
             this.configSelectionQueue = [];
-            this.callRefTimerUnref();
+            if (localQueue.length > 0) {
+                this.callRefTimerUnref();
+            }
             for (const call of localQueue) {
@@ -231,0 +236,0 @@ call.reportResolverError(status);

package.json

 {
   "name": "@grpc/grpc-js",
-  "version": "1.9.12",
+  "version": "1.9.13",
   "description": "gRPC Library for Node - pure JS implementation",
@@ -5,0 +5,0 @@ "homepage": "https://grpc.io/",

src/internal-channel.ts

@@ -299,3 +299,5 @@ /*
         this.pickQueue = [];
-        this.callRefTimerUnref();
+        if (queueCopy.length > 0) {
+          this.callRefTimerUnref();
+        }
         for (const call of queueCopy) {
@@ -353,7 +355,8 @@ call.doPick();
           this.configSelectionQueue = [];
-          this.callRefTimerUnref();
+          if (localQueue.length > 0) {
+            this.callRefTimerUnref();
+          }
           for (const call of localQueue) {
             call.getConfig();
           }
-          this.configSelectionQueue = [];
         });
@@ -385,3 +388,5 @@ },
         this.configSelectionQueue = [];
-        this.callRefTimerUnref();
+        if (localQueue.length > 0) {
+          this.callRefTimerUnref();
+        }
         for (const call of localQueue) {
@@ -388,0 +393,0 @@ call.reportResolverError(status);

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

1739948

increased by0.02%

Lines of code

35687

increased by0.03%

No dependency changes