995
996
dispose(): void {
997
>
for (const [, queue] of this.queues) {
async.ts
998
queue.dispose();
999
}
1001
>
this.queues.clear();
1002
>
1003
>
// Even though we might still have pending
1004
>
// tasks queued, after the queues have been
1005
>
// disposed, we can no longer track them, so
1006
>
// we release drainers to prevent hanging
1007
>
// promises when the resource queue is being
1008
>
// disposed.
1009
>
this.releaseDrainers();
1010
>
1011
>
this.drainListeners?.dispose();
1012
>
}
1013
}
1014