TaskPerformance,
WorkerStatistics
} from '../utility-types'
-import { EMPTY_FUNCTION, isPlainObject } from '../utils'
+import { EMPTY_FUNCTION, isAsyncFunction, isPlainObject } from '../utils'
import {
type KillBehavior,
KillBehaviors,
Response = unknown
> extends AsyncResource {
/**
- * Worker Id.
+ * Worker id.
*/
protected abstract id: number
/**
if (message.id != null && message.data != null) {
// Task message received
const fn = this.getTaskFunction(message.name)
- if (fn?.constructor.name === 'AsyncFunction') {
+ if (isAsyncFunction(fn)) {
this.runInAsyncScope(this.runAsync.bind(this), this, fn, message)
} else {
this.runInAsyncScope(this.runSync.bind(this), this, fn, message)
* Handles an error and convert it to a string so it can be sent back to the main worker.
*
* @param e - The error raised by the worker.
- * @returns Message of the error.
+ * @returns The error message.
*/
protected handleError (e: Error | string): string {
- return e as string
+ return e instanceof Error ? e.message : e
}
/**
id: message.id
})
} catch (e) {
- const err = this.handleError(e as Error)
+ const errorMessage = this.handleError(e as Error | string)
this.sendToMainWorker({
taskError: {
- message: err,
+ workerId: this.id,
+ message: errorMessage,
data: message.data
},
- workerId: this.id,
id: message.id
})
} finally {
return null
})
.catch(e => {
- const err = this.handleError(e as Error)
+ const errorMessage = this.handleError(e as Error | string)
this.sendToMainWorker({
taskError: {
- message: err,
+ workerId: this.id,
+ message: errorMessage,
data: message.data
},
- workerId: this.id,
id: message.id
})
})