Skip to content

Commit bb93256

Browse files
committed
fix(worker-dialect): reject with error instead of string
1 parent 4d7e0e3 commit bb93256

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

packages/dialect-bun-worker/src/driver.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -121,7 +121,7 @@ class BunWorkerConnection implements DatabaseConnection {
121121
this.worker.postMessage({ type: 'run', isSelect, sql, parameters } satisfies MainMsg)
122122
return new Promise((resolve, reject) => {
123123
if (!this.mitt) {
124-
reject('kysely instance has been destroyed')
124+
reject(new Error('kysely instance has been destroyed'))
125125
}
126126
this.mitt!.once('run', ({ data, err }) => {
127127
(!err && data) ? resolve(data) : reject(err)

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -110,7 +110,7 @@ export class SqliteWorkerConnection implements DatabaseConnection {
110110
this.worker.postMessage({ type: 'exec', sql, parameters } satisfies MainMsg)
111111
return new Promise((resolve, reject) => {
112112
if (!this.emit) {
113-
reject('kysely instance has been destroyed')
113+
reject(new Error('kysely instance has been destroyed'))
114114
}
115115
this.emit!.once('exec', (data: QueryResult<any>, err) => {
116116
(data && !err) ? resolve(data) : reject(err)

packages/dialect-wasqlite-worker/src/driver.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -133,7 +133,7 @@ class WaSqliteWorkerConnection implements DatabaseConnection {
133133
const isSelect = SelectQueryNode.is(query)
134134
this.worker.postMessage({ type: 'run', isSelect, sql, parameters } satisfies MainMsg)
135135
return new Promise((resolve, reject) => {
136-
!this.mitt && reject('kysely instance has been destroyed')
136+
!this.mitt && reject(new Error('kysely instance has been destroyed'))
137137

138138
this.mitt!.once('run', ({ data, err }) => {
139139
(!err && data) ? resolve(data) : reject(err)

0 commit comments

Comments
 (0)