Skip to content

Commit ede3f30

Browse files
committed
fix(dialect-generic-sqlite): cleanup worker and mitt after closing db
1 parent ebb7833 commit ede3f30

File tree

1 file changed

+9
-11
lines changed
  • packages/dialect-generic-sqlite/src/worker

1 file changed

+9
-11
lines changed

packages/dialect-generic-sqlite/src/worker/driver.ts

Lines changed: 9 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -60,17 +60,15 @@ export class GenericSqliteWorkerDriver<
6060
return
6161
}
6262
this.worker.postMessage([closeEvent] satisfies CloseMsg)
63-
return new Promise<void>((resolve, reject) => {
64-
this.mitt?.once(closeEvent, (_, err) => {
65-
if (err) {
66-
reject(err)
67-
} else {
68-
this.worker?.terminate()
69-
this.mitt?.off()
70-
this.mitt = this.worker = undefined
71-
resolve()
72-
}
73-
})
63+
return new Promise<void>(
64+
(resolve, reject) => this.mitt?.once(
65+
closeEvent,
66+
(_, err) => err ? reject(err) : resolve(),
67+
),
68+
).finally(() => {
69+
this.worker?.terminate()
70+
this.mitt?.off()
71+
this.mitt = this.worker = undefined
7472
})
7573
}
7674
}

0 commit comments

Comments
 (0)