X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Fworker%2Fthread-worker.test.js;h=495e10b13b92e2ff663ff1de551b65028a8a3841;hb=5388ef55be46ad29697a8f2f540bb732868c503b;hp=240534a75f94757293dd740ec20de8ef2e900cbf;hpb=d56f6cfde3b9eeb2a5e4341b91ec474580a0c07a;p=poolifier.git diff --git a/tests/worker/thread-worker.test.js b/tests/worker/thread-worker.test.js index 240534a7..495e10b1 100644 --- a/tests/worker/thread-worker.test.js +++ b/tests/worker/thread-worker.test.js @@ -1,9 +1,29 @@ -const expect = require('expect') +const { expect } = require('expect') const { ThreadWorker } = require('../../lib') describe('Thread worker test suite', () => { - it('Verify worker has default maxInactiveTime', () => { + let numberOfMessagesPosted = 0 + const postMessage = () => { + ++numberOfMessagesPosted + } + class SpyWorker extends ThreadWorker { + constructor (fn) { + super(fn) + this.port = { postMessage } + } + } + + it('Verify that handleError() method is working properly', () => { + const error = new Error('Error as an error') const worker = new ThreadWorker(() => {}) - expect(worker.maxInactiveTime).toEqual(60_000) + expect(worker.handleError(error)).toStrictEqual(error) + const errorMessage = 'Error as a string' + expect(worker.handleError(errorMessage)).toStrictEqual(errorMessage) + }) + + it('Verify worker invokes the postMessage() method on port property', () => { + const worker = new SpyWorker(() => {}) + worker.sendToMainWorker({ ok: 1 }) + expect(numberOfMessagesPosted).toBe(1) }) })