Remove duplicate AsyncQueue from fsm runtime, use queue.ts

Author: polRk

packages/fsm/src/runtime.ts

@@ -7,86 +7,7 @@ import type {
 	RuntimeOptions,
 	TransitionRuntime,
 } from './types.js'
-
-class QueueClosedError extends Error {
-	constructor(message = 'Queue is closed') {
-		super(message)
-		this.name = 'QueueClosedError'
-	}
-}
-
-class AsyncQueue<T> implements AsyncIterable<T> {
-	#queue: T[] = []
-	#waiters: Array<{ resolve: (value: IteratorResult<T>) => void }> = []
-	#closed = false
-
-	push(item: T): void {
-		if (this.#closed) {
-			throw new QueueClosedError()
-		}
-
-		let waiter = this.#waiters.shift()
-		if (waiter) {
-			waiter.resolve({ value: item, done: false })
-			return
-		}
-
-		this.#queue.push(item)
-	}
-
-	close(): void {
-		if (this.#closed) {
-			return
-		}
-
-		this.#closed = true
-
-		// Signal waiting iterators that no more items will be pushed.
-		// Buffered items are not cleared — iterators drain them before exiting.
-		while (this.#waiters.length > 0) {
-			let waiter = this.#waiters.shift()
-			if (!waiter) {
-				continue
-			}
-			waiter.resolve({ value: undefined as never, done: true })
-		}
-	}
-
-	get isClosed(): boolean {
-		return this.#closed
-	}
-
-	async *[Symbol.asyncIterator](): AsyncIterator<T> {
-		while (true) {
-			if (this.#queue.length > 0) {
-				let value = this.#queue.shift() as T
-				yield value
-				continue
-			}
-
-			if (this.#closed) {
-				return
-			}
-
-			let waiter = new Promise<IteratorResult<T>>((resolve) => {
-				this.#waiters.push({ resolve })
-			})
-
-			// oxlint-disable-next-line no-await-in-loop
-			let result = await waiter
-			if (result.done) {
-				// Drain items buffered between the last yield and the close signal.
-				while (this.#queue.length > 0) {
-					let value = this.#queue.shift() as T
-					yield value
-				}
-				return
-			}
-
-			yield result.value
-		}
-	}
-}
+import { AsyncQueue } from './queue.js'
 
 type InternalEventEnvelope<E> = {
 	event: E