X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Fworker%2Fthread-worker.test.js;h=0024fe0a212726834b97b0d39679d5b86f8a5030;hb=4f4ae1cb3c33228a023ea599c2648268d15e6c0f;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..0024fe0a 100644 --- a/tests/worker/thread-worker.test.js +++ b/tests/worker/thread-worker.test.js @@ -1,9 +1,25 @@ const expect = require('expect') const { ThreadWorker } = require('../../lib') +let numberOfMessagesPosted = 0 +const postMessage = function () { + numberOfMessagesPosted++ +} +class SpyWorker extends ThreadWorker { + getMainWorker () { + return { postMessage: postMessage } + } +} + describe('Thread worker test suite', () => { it('Verify worker has default maxInactiveTime', () => { const worker = new ThreadWorker(() => {}) - expect(worker.maxInactiveTime).toEqual(60_000) + expect(worker.opts.maxInactiveTime).toEqual(60_000) + }) + + it('Verify worker invoke the getMainWorker and postMessage methods', () => { + const worker = new SpyWorker(() => {}) + worker.sendToMainWorker({ ok: 1 }) + expect(numberOfMessagesPosted).toBe(1) }) })