- // Skipped because ClusterWorker would be in main instead of non-main worker
- it.skip('Verify worker has default maxInactiveTime', () => {
- const worker = new ClusterWorker(() => {})
- expect(worker.maxInactiveTime).toEqual(60_000)
+ let numberOfMessagesSent = 0
+ const send = () => {
+ ++numberOfMessagesSent
+ }
+ class SpyWorker extends ClusterWorker {
+ getMainWorker () {
+ return { send }
+ }
+ }
+
+ it('Verify worker invokes the getMainWorker() and send() methods', () => {
+ const worker = new SpyWorker(() => {})
+ worker.sendToMainWorker({ ok: 1 })
+ expect(numberOfMessagesSent).toBe(1)