From 66487229ccd28da113b9d98613e96b8fa22d9fc9 Mon Sep 17 00:00:00 2001 From: Patrik Oldsberg Date: Mon, 27 May 2024 11:51:41 +0200 Subject: [PATCH] events-backend: fix for memory store not timing out listeners Signed-off-by: Patrik Oldsberg --- plugins/events-backend/src/service/hub/MemoryEventBusStore.ts | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/plugins/events-backend/src/service/hub/MemoryEventBusStore.ts b/plugins/events-backend/src/service/hub/MemoryEventBusStore.ts index 1e95efc3de..629c341a76 100644 --- a/plugins/events-backend/src/service/hub/MemoryEventBusStore.ts +++ b/plugins/events-backend/src/service/hub/MemoryEventBusStore.ts @@ -111,12 +111,13 @@ export class MemoryEventBusStore implements EventBusStore { throw new Error(`Subscription not found`); } - return new Promise<{ topic: string }>(resolve => { + return new Promise<{ topic: string }>((resolve, reject) => { const listener = { topics: sub.topics, resolve }; this.#listeners.add(listener); options.signal.addEventListener('abort', () => { this.#listeners.delete(listener); + reject(options.signal.reason); }); }); },