diff --git a/src/index.ts b/src/index.ts index 80f41d45..c0bef97b 100644 --- a/src/index.ts +++ b/src/index.ts @@ -636,6 +636,7 @@ export class GossipSub extends EventEmitter implements PubSub registrar.unhandle(multicodec))) registrarTopologyIds.forEach((id) => registrar.unregister(id)) this.outboundInflightQueue.end()