during stream setup also inc active to avoid the core closing underne…

…ath us
holepunchto · Sep 16, 2024 · a3b81f8 · a3b81f8
1 parent d672aac
commit a3b81f8
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/lib/replicator.js b/lib/replicator.js
@@ -2295,8 +2295,11 @@ module.exports = class Replicator {
     protomux.stream.setMaxListeners(0)
     protomux.stream.on('close', this._onstreamclose)
 
+    if (useSession) this.core.active++
     this._ifAvailable++
+
     protomux.stream.opened.then((opened) => {
+      if (useSession) this.core.active--
       this._ifAvailable--
 
       if (opened && !this.destroyed) makePeer()