events-backend: fix for memory store not timing out listeners
Signed-off-by: Patrik Oldsberg <poldsberg@gmail.com>
This commit is contained in:
@@ -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);
|
||||
});
|
||||
});
|
||||
},
|
||||
|
||||
Reference in New Issue
Block a user