Fix abort listener leak in fsm runtime

Signed-off-by: Vladislav Polyakov <polRk@ydb.tech>

Author: polRk

.changeset/mghxjzdsqj.md

@@ -0,0 +1,12 @@
+---
+'@ydbjs/fsm': patch
+---
+
+Fix memory leak in event ingestion caused by `AbortSignal.any()`
+
+`AbortSignal.any()` registers event listeners on all source signals but never removes them, leading to a listener leak every time an event source is ingested. Replace it with `linkSignals` from `@ydbjs/abortable@^6.1.0`, which uses `Symbol.dispose` to clean up listeners when the ingestion task completes.
+
+Additional improvements:
+
+- Use `combined.signal` instead of `combined` directly for abort checks (correct API usage)
+- Separate abort signal checks from internal state checks for better readability and clearer control flow

package-lock.json

@@ -42,6 +42,9 @@
 		"test": "tsc -b tsconfig.test.json && vitest --run",
 		"attw": "attw --pack --profile esm-only"
 	},
+	"dependencies": {
+		"@ydbjs/abortable": "^6.1.0"
+	},
 	"files": [
 		"dist",
 		"!dist/.tsbuildinfo",

packages/fsm/package.json

@@ -1,3 +1,6 @@
+import { linkSignals } from '@ydbjs/abortable'
+
+import { AsyncQueue } from './queue.js'
 import type {
 	EffectRuntime,
 	IngestHandle,
@@ -7,7 +10,6 @@ import type {
 	RuntimeOptions,
 	TransitionRuntime,
 } from './types.js'
-import { AsyncQueue } from './queue.js'
 
 type InternalEventEnvelope<E> = {
 	event: E
@@ -87,14 +89,16 @@ class Runtime<
 		}
 
 		let ac = new AbortController()
-		let combined = signal
-			? AbortSignal.any([signal, ac.signal, this.signal])
-			: AbortSignal.any([ac.signal, this.signal])
+		let combined = linkSignals(signal, ac.signal, this.signal)
 
 		let task = (async () => {
 			try {
 				for await (let input of source) {
-					if (combined.aborted || this.#closing || this.#closed || this.#destroyed) {
+					if (combined.signal.aborted) {
+						return
+					}
+
+					if (this.#closing || this.#closed || this.#destroyed) {
 						return
 					}
 
@@ -104,7 +108,11 @@ class Runtime<
 					}
 				}
 			} catch (error) {
-				if (combined.aborted || this.#closing || this.#closed || this.#destroyed) {
+				if (combined.signal.aborted) {
+					return
+				}
+
+				if (this.#closing || this.#closed || this.#destroyed) {
 					return
 				}