@grpc/grpc-js - npm Package Compare versions

Comparing version 1.8.9 to 1.8.10

build/src/internal-channel.d.ts

@@ -29,4 +29,4 @@ import { ChannelCredentials } from './channel-credentials';
     private channel;
-    private stateListeners;
     private refCount;
+    private subchannelStateListener;
     constructor(childSubchannel: SubchannelInterface, channel: InternalChannel);
@@ -33,0 +33,0 @@ ref(): void;

build/src/internal-channel.js

@@ -52,10 +52,7 @@ "use strict";
         this.channel = channel;
-        this.stateListeners = [];
         this.refCount = 0;
-        childSubchannel.addConnectivityStateListener((subchannel, previousState, newState, keepaliveTime) => {
+        this.subchannelStateListener = (subchannel, previousState, newState, keepaliveTime) => {
             channel.throttleKeepalive(keepaliveTime);
-            for (const listener of this.stateListeners) {
-                listener(this, previousState, newState, keepaliveTime);
-            }
-        });
+        };
+        childSubchannel.addConnectivityStateListener(this.subchannelStateListener);
     }
@@ -70,2 +67,3 @@ ref() {
         if (this.refCount <= 0) {
+            this.child.removeConnectivityStateListener(this.subchannelStateListener);
             this.channel.removeWrappedSubchannel(this);
@@ -72,0 +70,0 @@ }

build/src/load-balancer-pick-first.js

@@ -119,3 +119,3 @@ "use strict";
              * delay timer. */
-            if (subchannel === this.subchannels[this.currentSubchannelIndex] &&
+            if (subchannel.getRealSubchannel() === this.subchannels[this.currentSubchannelIndex].getRealSubchannel() &&
                 newState === connectivity_state_1.ConnectivityState.TRANSIENT_FAILURE) {
@@ -330,3 +330,3 @@ this.startNextSubchannelConnecting();
         if (this.subchannels.length === 0 ||
-            !this.latestAddressList.every((value, index) => addressList[index] === value)) {
+            !this.latestAddressList.every((value, index) => (0, subchannel_address_1.subchannelAddressEqual)(addressList[index], value))) {
             this.latestAddressList = addressList;
@@ -333,0 +333,0 @@ this.connectToAddressList();

package.json

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

src/internal-channel.ts

@@ -89,12 +89,10 @@ /*
 class ChannelSubchannelWrapper extends BaseSubchannelWrapper implements SubchannelInterface {
-  private stateListeners: ConnectivityStateListener[] = [];
   private refCount = 0;
+  private subchannelStateListener: ConnectivityStateListener;
   constructor(childSubchannel: SubchannelInterface, private channel: InternalChannel) {
     super(childSubchannel);
-    childSubchannel.addConnectivityStateListener((subchannel, previousState, newState, keepaliveTime) => {
+    this.subchannelStateListener = (subchannel, previousState, newState, keepaliveTime) => {
       channel.throttleKeepalive(keepaliveTime);
-      for (const listener of this.stateListeners) {
-        listener(this, previousState, newState, keepaliveTime);
-      }
-    });
+    };
+    childSubchannel.addConnectivityStateListener(this.subchannelStateListener);
   }
@@ -111,2 +109,3 @@
     if (this.refCount <= 0) {
+      this.child.removeConnectivityStateListener(this.subchannelStateListener);
       this.channel.removeWrappedSubchannel(this);
@@ -113,0 +112,0 @@ }

src/load-balancer-pick-first.ts

@@ -36,2 +36,3 @@ /*
   SubchannelAddress,
+  subchannelAddressEqual,
   subchannelAddressToString,
@@ -172,3 +173,3 @@ } from './subchannel-address';
       if (
-        subchannel === this.subchannels[this.currentSubchannelIndex] &&
+        subchannel.getRealSubchannel() === this.subchannels[this.currentSubchannelIndex].getRealSubchannel() &&
         newState === ConnectivityState.TRANSIENT_FAILURE
@@ -425,3 +426,3 @@ ) {
       !this.latestAddressList.every(
-        (value, index) => addressList[index] === value
+        (value, index) => subchannelAddressEqual(addressList[index], value)
       )
@@ -428,0 +429,0 @@ ) {

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

1694800

increased by0.01%

Worsened metrics

Lines of code

33582

decreased by-0.01%

No dependency changes