Skip to content

Commit 2eddaf5

Browse files
fix: condition for ping failure
1 parent 5970e65 commit 2eddaf5

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

packages/sdk/src/protocols/filter/reliability_monitor.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -123,7 +123,7 @@ export class ReceiverReliabilityMonitor {
123123
const failures = (this.peerFailures.get(peerId.toString()) || 0) + 1;
124124
this.peerFailures.set(peerId.toString(), failures);
125125

126-
if (failures > this.maxPingFailures) {
126+
if (failures >= this.maxPingFailures) {
127127
try {
128128
await this.renewAndSubscribePeer(peerId);
129129
this.peerFailures.delete(peerId.toString());

0 commit comments

Comments
 (0)