X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Fworker%2Fabstract-worker.test.js;h=68665bc442fd540c9daaba0163340825ed347c29;hb=e57eb4d0ea721c4dea66047c431d516f74270453;hp=46370777f4e1fcb5e1df8cef70ecdff08472578f;hpb=07588f306649b9df235aaf65de4842e99532ed6a;p=poolifier.git diff --git a/tests/worker/abstract-worker.test.js b/tests/worker/abstract-worker.test.js index 46370777..68665bc4 100644 --- a/tests/worker/abstract-worker.test.js +++ b/tests/worker/abstract-worker.test.js @@ -132,7 +132,12 @@ describe('Abstract worker test suite', () => { killHandler: sinon.stub().returns() }) worker.isMain = false + worker.getMainWorker = sinon.stub().returns({ + id: 1, + send: sinon.stub().returns() + }) worker.handleKillMessage() + expect(worker.getMainWorker().send.calledOnce).toBe(true) expect(worker.opts.killHandler.calledOnce).toBe(true) }) @@ -221,6 +226,10 @@ describe('Abstract worker test suite', () => { return 2 } const worker = new ClusterWorker({ fn1, fn2 }) + worker.getMainWorker = sinon.stub().returns({ + id: 1, + send: sinon.stub().returns() + }) expect(worker.taskFunctions.get('default')).toBeInstanceOf(Function) expect(worker.taskFunctions.get('fn1')).toBeInstanceOf(Function) expect(worker.taskFunctions.get('fn2')).toBeInstanceOf(Function) @@ -243,6 +252,7 @@ describe('Abstract worker test suite', () => { expect(worker.taskFunctions.get('fn1')).toBeInstanceOf(Function) expect(worker.taskFunctions.get('fn2')).toBeUndefined() expect(worker.taskFunctions.size).toBe(2) + expect(worker.getMainWorker().send.calledOnce).toBe(true) }) it('Verify that listTaskFunctions() works', () => {