refactor: implement AsyncIterable and Disposable interfaces in PQueue for improved functionality

Signed-off-by: Vladislav Polyakov <[email protected]>

Author: polRk

packages/topic/src/queue.ts

@@ -1,8 +1,8 @@
-export class PQueue<T> {
-	private heap: { value: T; priority: number }[] = [];
+export class PQueue<T> implements AsyncIterable<T>, Disposable {
 	private closed = false;
-	private pendingShifts: ((value: IteratorResult<T>) => void)[] = [];
-	private pendingRejects: ((reason?: any) => void)[] = [];
+	private readonly heap: { value: T; priority: number }[] = [];
+	private readonly pendingShifts: ((value: IteratorResult<T>) => void)[] = [];
+	private readonly pendingRejects: ((reason?: any) => void)[] = [];
 
 	get size(): number {
 		return this.heap.length;
@@ -96,4 +96,11 @@ export class PQueue<T> {
 			yield value;
 		}
 	}
+
+	[Symbol.dispose]() {
+		this.close();
+		this.heap.length = 0;
+		this.pendingShifts.length = 0;
+		this.pendingRejects.length = 0;
+	}
 }