fix: condition for ping failure

waku-org · Sep 12, 2024 · 2eddaf5 · 2eddaf5
1 parent 5970e65
commit 2eddaf5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/packages/sdk/src/protocols/filter/reliability_monitor.ts b/packages/sdk/src/protocols/filter/reliability_monitor.ts
@@ -123,7 +123,7 @@ export class ReceiverReliabilityMonitor {
     const failures = (this.peerFailures.get(peerId.toString()) || 0) + 1;
     this.peerFailures.set(peerId.toString(), failures);
 
-    if (failures > this.maxPingFailures) {
+    if (failures >= this.maxPingFailures) {
       try {
         await this.renewAndSubscribePeer(peerId);
         this.peerFailures.delete(peerId.toString());