(message: unknown)
| 979 | }, 10000) |
| 980 | |
| 981 | const readyHandler = (message: unknown) => { |
| 982 | if ( |
| 983 | typeof message === 'object' && |
| 984 | message !== null && |
| 985 | (message as { type?: string }).type === 'ready' |
| 986 | ) { |
| 987 | if (!settleSpawnInProgress()) { |
| 988 | proc.off('message', readyHandler) |
| 989 | return |
| 990 | } |
| 991 | workerInfo.ready = true |
| 992 | clearTimeout(startTimeout) |
| 993 | proc.off('message', readyHandler) |
| 994 | workers.set(workerId, workerInfo) |
| 995 | resetWorkerIdleTimeout(workerId) |
| 996 | logger.info('Worker spawned and ready', { workerId, poolSize: workers.size }) |
| 997 | resolve() |
| 998 | } |
| 999 | } |
| 1000 | proc.on('message', readyHandler) |
| 1001 | |
| 1002 | proc.on('exit', () => { |
nothing calls this directly
no test coverage detected