fix: forward errors from WorkerThreads to consumers

nytamin · Jul 21, 2022 · 9a36299 · 9a36299
1 parent cd379f1
commit 9a36299
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/src/parent-process/workerPlatform/webWorkers.ts b/src/parent-process/workerPlatform/webWorkers.ts
@@ -19,10 +19,10 @@ export class WebWorkerProcess extends WorkerPlatformBase {
 				} else console.log('unknown message type', message)
 			}
 			this.worker.onmessageerror = (error: any) => {
-				console.error('ww message error', error)
+				this.emit('error', error)
 			}
 			this.worker.onerror = (error: any) => {
-				console.error('ww error', error)
+				this.emit('error', error)
 			}
 		} catch (error) {
 			let str = (error.stack || error).toString() + ''

diff --git a/src/parent-process/workerPlatform/workerThreads.ts b/src/parent-process/workerPlatform/workerThreads.ts
@@ -49,8 +49,11 @@ export class WorkerThread extends WorkerPlatformBase {
 			// if (message.type === 'message') {
 			// } else console.log('unknown message type', message)
 		})
+		this.worker.on('messageerror', (error: any) => {
+			this.emit('error', error)
+		})
 		this.worker.on('error', (error: any) => {
-			console.error('Worker Thread error', error)
+			this.emit('error', error)
 		})
 		this.worker.on('exit', (_code: number) => {
 			this.emit('close')