[poolifier.git] / tests / worker / cluster-worker.test.js

const { expect } = require('expect')
const { ClusterWorker } = require('../../lib')

describe('Cluster worker test suite', () => {
  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)
  })
})
Commit	Line	Data
a61a0724	1	const { expect } = require('expect')
fd027a65 S	2	const { ClusterWorker } = require('../../lib')
	3
	4	describe('Cluster worker test suite', () => {
f4fb3543	5	let numberOfMessagesSent = 0
440dd7d7	6	const send = () => {
f4fb3543 JB	7	++numberOfMessagesSent
	8	}
	9	class SpyWorker extends ClusterWorker {
	10	getMainWorker () {
	11	return { send }
	12	}
	13	}
	14
2431bdb4	15	it('Verify worker invokes the getMainWorker() and send() methods', () => {
f4fb3543 JB	16	const worker = new SpyWorker(() => {})
	17	worker.sendToMainWorker({ ok: 1 })
	18	expect(numberOfMessagesSent).toBe(1)
	19	})
fd027a65	20	})