X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Fworker%2Fthread-worker.test.js;h=495e10b13b92e2ff663ff1de551b65028a8a3841;hb=368019dd961273898357919aad6c0c4229b9e2b4;hp=c08adffd9816a9c0f4bd78337b857a664fa4553f;hpb=2431bdb4c2dc637169bf623a40fc6562f685e56e;p=poolifier.git diff --git a/tests/worker/thread-worker.test.js b/tests/worker/thread-worker.test.js index c08adffd..495e10b1 100644 --- a/tests/worker/thread-worker.test.js +++ b/tests/worker/thread-worker.test.js @@ -3,20 +3,16 @@ const { ThreadWorker } = require('../../lib') describe('Thread worker test suite', () => { let numberOfMessagesPosted = 0 - const postMessage = function () { + const postMessage = () => { ++numberOfMessagesPosted } class SpyWorker extends ThreadWorker { - getMainWorker () { - return { postMessage } + constructor (fn) { + super(fn) + this.port = { postMessage } } } - it('Verify worker has default maxInactiveTime', () => { - const worker = new ThreadWorker(() => {}) - expect(worker.opts.maxInactiveTime).toStrictEqual(60000) - }) - it('Verify that handleError() method is working properly', () => { const error = new Error('Error as an error') const worker = new ThreadWorker(() => {}) @@ -25,7 +21,7 @@ describe('Thread worker test suite', () => { expect(worker.handleError(errorMessage)).toStrictEqual(errorMessage) }) - it('Verify worker invokes the getMainWorker() and postMessage() methods', () => { + it('Verify worker invokes the postMessage() method on port property', () => { const worker = new SpyWorker(() => {}) worker.sendToMainWorker({ ok: 1 }) expect(numberOfMessagesPosted).toBe(1)