repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
refactor: cleanup exports
[poolifier.git]
/
tests
/
pools
/
worker-node.test.mjs
diff --git
a/tests/pools/worker-node.test.mjs
b/tests/pools/worker-node.test.mjs
index cfca3422b0f3ff727138608a65f7542dff63ba35..3b87a8485d39e0547707197c8667238ec35a0265 100644
(file)
--- a/
tests/pools/worker-node.test.mjs
+++ b/
tests/pools/worker-node.test.mjs
@@
-1,4
+1,5
@@
-import { MessageChannel } from 'node:worker_threads'
+import { MessageChannel, Worker as ThreadWorker } from 'node:worker_threads'
+import { Worker as ClusterWorker } from 'node:cluster'
import { expect } from 'expect'
import { WorkerNode } from '../../lib/pools/worker-node.js'
import { WorkerTypes } from '../../lib/index.js'
import { expect } from 'expect'
import { WorkerNode } from '../../lib/pools/worker-node.js'
import { WorkerTypes } from '../../lib/index.js'
@@
-118,6
+119,7
@@
describe('Worker node test suite', () => {
)
)
expect(threadWorkerNode).toBeInstanceOf(WorkerNode)
)
)
expect(threadWorkerNode).toBeInstanceOf(WorkerNode)
+ expect(threadWorkerNode.worker).toBeInstanceOf(ThreadWorker)
expect(threadWorkerNode.info).toStrictEqual({
id: threadWorkerNode.worker.threadId,
type: WorkerTypes.thread,
expect(threadWorkerNode.info).toStrictEqual({
id: threadWorkerNode.worker.threadId,
type: WorkerTypes.thread,
@@
-160,6
+162,7
@@
describe('Worker node test suite', () => {
expect(threadWorkerNode.taskFunctionsUsage).toBeInstanceOf(Map)
expect(clusterWorkerNode).toBeInstanceOf(WorkerNode)
expect(threadWorkerNode.taskFunctionsUsage).toBeInstanceOf(Map)
expect(clusterWorkerNode).toBeInstanceOf(WorkerNode)
+ expect(clusterWorkerNode.worker).toBeInstanceOf(ClusterWorker)
expect(clusterWorkerNode.info).toStrictEqual({
id: clusterWorkerNode.worker.id,
type: WorkerTypes.cluster,
expect(clusterWorkerNode.info).toStrictEqual({
id: clusterWorkerNode.worker.id,
type: WorkerTypes.cluster,