+ expect(result).toStrictEqual({ ok: 1 })
+ })
+
+ it("Verify that 'ready' event is emitted", async () => {
+ const pool = new FixedThreadPool(
+ numberOfThreads,
+ './tests/worker-files/thread/testWorker.js',
+ {
+ errorHandler: e => console.error(e)
+ }
+ )
+ expect(pool.emitter.eventNames()).toStrictEqual([])
+ let poolReady = 0
+ pool.emitter.on(PoolEvents.ready, () => ++poolReady)
+ await waitPoolEvents(pool, PoolEvents.ready, 1)
+ expect(pool.emitter.eventNames()).toStrictEqual([PoolEvents.ready])
+ expect(poolReady).toBe(1)
+ await pool.destroy()