We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent bca9806 commit 3a98dd5Copy full SHA for 3a98dd5
1 file changed
packages/sqlite/src/mq.ts
@@ -350,9 +350,13 @@ export class SqliteMessageQueue implements MessageQueue, Disposable {
350
while (signal == null || !signal.aborted) {
351
let timeout: ReturnType<typeof setTimeout> | undefined;
352
await new Promise<unknown>((resolve) => {
353
- signal?.addEventListener("abort", resolve);
+ const onAbort = () => {
354
+ signal?.removeEventListener("abort", onAbort);
355
+ resolve(undefined);
356
+ };
357
+ signal?.addEventListener("abort", onAbort);
358
timeout = setTimeout(() => {
- signal?.removeEventListener("abort", resolve);
359
360
resolve(0);
361
}, this.#pollIntervalMs);
362
timeouts.add(timeout);
0 commit comments