ensure all peers are removed

holepunchto · Oct 1, 2024 · 008a396 · 008a396
1 parent b8cd2e0
commit 008a396
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/lib/replicator.js b/lib/replicator.js
@@ -2327,9 +2327,10 @@ module.exports = class Replicator {
  clearTimeout(this._downloadingTimer)
  this._downloadingTimer = null
  }
- for (const peer of this.peers) {
+ while (this.peers.length) {
+ const peer = this.peers[this.peers.length - 1]
  this.detachFrom(peer.protomux)
- peer.channel.close()
+ peer.channel.close() // peer is removed from array in onclose
  }
  for (const protomux of this._attached) {
  this.detachFrom(protomux)