repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge pull request #786 from poolifier/worker-info
[poolifier.git]
/
tests
/
worker
/
abstract-worker.test.js
diff --git
a/tests/worker/abstract-worker.test.js
b/tests/worker/abstract-worker.test.js
index 260e5b882310814b37a3cbd25c985939406a897a..e5bf4c81005f94a33cee53bc2f04a10b48549847 100644
(file)
--- a/
tests/worker/abstract-worker.test.js
+++ b/
tests/worker/abstract-worker.test.js
@@
-2,7
+2,7
@@
const { expect } = require('expect')
const { ClusterWorker, KillBehaviors, ThreadWorker } = require('../../lib')
describe('Abstract worker test suite', () => {
const { ClusterWorker, KillBehaviors, ThreadWorker } = require('../../lib')
describe('Abstract worker test suite', () => {
- class Stub
PoolWithIs
MainWorker extends ThreadWorker {
+ class Stub
WorkerWith
MainWorker extends ThreadWorker {
constructor (fn, opts) {
super(fn, opts)
this.mainWorker = undefined
constructor (fn, opts) {
super(fn, opts)
this.mainWorker = undefined
@@
-13,7
+13,7
@@
describe('Abstract worker test suite', () => {
const worker = new ThreadWorker(() => {})
expect(worker.opts.maxInactiveTime).toStrictEqual(60000)
expect(worker.opts.killBehavior).toBe(KillBehaviors.SOFT)
const worker = new ThreadWorker(() => {})
expect(worker.opts.maxInactiveTime).toStrictEqual(60000)
expect(worker.opts.killBehavior).toBe(KillBehaviors.SOFT)
- expect(worker.opts.async).toBe(
false
)
+ expect(worker.opts.async).toBe(
undefined
)
})
it('Verify that worker options are set at worker creation', () => {
})
it('Verify that worker options are set at worker creation', () => {
@@
-24,7
+24,7
@@
describe('Abstract worker test suite', () => {
})
expect(worker.opts.maxInactiveTime).toStrictEqual(6000)
expect(worker.opts.killBehavior).toBe(KillBehaviors.HARD)
})
expect(worker.opts.maxInactiveTime).toStrictEqual(6000)
expect(worker.opts.killBehavior).toBe(KillBehaviors.HARD)
- expect(worker.opts.async).toBe(
true
)
+ expect(worker.opts.async).toBe(
undefined
)
})
it('Verify that taskFunctions parameter is mandatory', () => {
})
it('Verify that taskFunctions parameter is mandatory', () => {
@@
-113,7
+113,7
@@
describe('Abstract worker test suite', () => {
it('Verify that getMainWorker() throw error if main worker is not set', () => {
expect(() =>
it('Verify that getMainWorker() throw error if main worker is not set', () => {
expect(() =>
- new Stub
PoolWithIs
MainWorker(() => {}).getMainWorker()
- ).toThrowError('Main worker
was
not set')
+ new Stub
WorkerWith
MainWorker(() => {}).getMainWorker()
+ ).toThrowError('Main worker not set')
})
})
})
})