logos-messaging/js-waku
1
0
Fork 0
mirror of https://github.com/logos-messaging/js-waku.git synced 2026-02-05 14:33:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: add stopAllRetries method to RetryManager for proper cleanup

Browse Source
This commit is contained in:
Levente Kiss 2025-10-31 18:39:15 +13:00
parent 404d590a86
commit 9793b40275
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
packages/sdk/src/reliable_channel/retry_manager.ts
View File

@ -24,9 +24,17 @@ export class RetryManager {
const timeout = this.timeouts.get(id);
if (timeout) {
clearTimeout(timeout);
this.timeouts.delete(id);
}
}
public stopAllRetries(): void {
for (const [_id, timeout] of this.timeouts.entries()) {
clearTimeout(timeout);
}
this.timeouts.clear();
}
public startRetries(id: string, retry: () => void | Promise<void>): void {
this.retry(id, retry, 0);
}
@ -36,7 +44,7 @@ export class RetryManager {
retry: () => void | Promise<void>,
attemptNumber: number
): void {
clearTimeout(this.timeouts.get(id));
this.stopRetries(id);
if (attemptNumber < this.maxRetryNumber) {
const interval = setTimeout(() => {
void retry();