diff --git a/packages/sdk/src/protocols/filter/subscription_manager.ts b/packages/sdk/src/protocols/filter/subscription_manager.ts index 70fccae33f..51a9e16e8d 100644 --- a/packages/sdk/src/protocols/filter/subscription_manager.ts +++ b/packages/sdk/src/protocols/filter/subscription_manager.ts @@ -20,10 +20,8 @@ import { import { WakuMessage } from "@waku/proto"; import { groupByContentTopic, Logger } from "@waku/utils"; -import { - ReceiverReliabilityMonitor, - ReliabilityMonitorManager -} from "../../reliability_monitor/receiver.js"; +import { ReliabilityMonitorManager } from "../../reliability_monitor/index.js"; +import { ReceiverReliabilityMonitor } from "../../reliability_monitor/receiver.js"; import { DEFAULT_KEEP_ALIVE, DEFAULT_SUBSCRIBE_OPTIONS } from "./constants.js"; diff --git a/packages/sdk/src/waku.ts b/packages/sdk/src/waku.ts index 2ed722ac1c..a5314a99f8 100644 --- a/packages/sdk/src/waku.ts +++ b/packages/sdk/src/waku.ts @@ -196,7 +196,7 @@ export class WakuNode implements Waku { } public async stop(): Promise { - ReliabilityMonitorManager.destroyAll(); + ReliabilityMonitorManager.stopAll(); this.connectionManager.stop(); await this.libp2p.stop(); }