diff --git a/src/WorkerPool.js b/src/WorkerPool.js index 0ab591b..545c297 100644 --- a/src/WorkerPool.js +++ b/src/WorkerPool.js @@ -131,7 +131,7 @@ class PoolWorker { const { context, request, questionId } = message; const { data } = this.jobs[id]; data.resolve(context, request, (error, result) => { - this.worker.send({ + this.writeJson({ type: 'result', id: questionId, error,