grpc-js: Fix tracking of active calls in transport

grpc · Jan 25, 2023 · 0d177a8 · 0d177a8
1 parent f29e99d
commit 0d177a8
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/packages/grpc-js/src/transport.ts b/packages/grpc-js/src/transport.ts
@@ -354,16 +354,20 @@ class Http2Transport implements Transport {
 
  private removeActiveCall(call: Http2SubchannelCall) {
  this.activeCalls.delete(call);
- if (this.activeCalls.size === 0 && !this.keepaliveWithoutCalls) {
+ if (this.activeCalls.size === 0) {
  this.session.unref();
- this.stopKeepalivePings();
+ if (!this.keepaliveWithoutCalls) {
+ this.stopKeepalivePings();
+ }
  }
  }
 
  private addActiveCall(call: Http2SubchannelCall) {
- if (this.activeCalls.size === 0 && !this.keepaliveWithoutCalls) {
+ if (this.activeCalls.size === 0) {
  this.session.ref();
- this.startKeepalivePings();
+ if (!this.keepaliveWithoutCalls) {
+ this.startKeepalivePings();
+ }
  }
  this.activeCalls.add(call);
  }