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

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

let numberOfMessagesPosted = 0
const postMessage = function (message) {
  numberOfMessagesPosted++
  console.log(message)
}
class SpyWorker extends ThreadWorker {
  getMainWorker () {
    return { postMessage: postMessage }
  }
}

describe('Thread worker test suite', () => {
  it('Verify worker has default maxInactiveTime', () => {
    const worker = new ThreadWorker(() => {})
    expect(worker.maxInactiveTime).toEqual(60_000)
  })

  it('Verify worker invoke the getMainWorker and postMessage methods', () => {
    const worker = new SpyWorker(() => {})
    worker.sendToMainWorker({ ok: 1 })
    expect(numberOfMessagesPosted).toBe(1)
  })
})
Commit	Line	Data
fd027a65 S	1	const expect = require('expect')
	2	const { ThreadWorker } = require('../../lib')
	3
74a2a194 APA	4	let numberOfMessagesPosted = 0
	5	const postMessage = function (message) {
	6	numberOfMessagesPosted++
	7	console.log(message)
	8	}
	9	class SpyWorker extends ThreadWorker {
	10	getMainWorker () {
	11	return { postMessage: postMessage }
	12	}
	13	}
	14
fd027a65 S	15	describe('Thread worker test suite', () => {
	16	it('Verify worker has default maxInactiveTime', () => {
	17	const worker = new ThreadWorker(() => {})
	18	expect(worker.maxInactiveTime).toEqual(60_000)
	19	})
74a2a194 APA	20
	21	it('Verify worker invoke the getMainWorker and postMessage methods', () => {
	22	const worker = new SpyWorker(() => {})
	23	worker.sendToMainWorker({ ok: 1 })
	24	expect(numberOfMessagesPosted).toBe(1)
	25	})
fd027a65	26	})