in src/worker-pool.ts [71:87]
private spawnWorker() {
const worker = cluster.fork();
const subject = new BehaviorSubject(worker);
this.workers.unshift({ worker: subject, active: 0 });
worker.on('exit', (code, signal) => subject.error(new WorkerExitedError(code ?? signal)));
worker.on('error', (err) => subject.error(err));
worker.send({
mode: this.options.check
? WorkerMode.Assert
: this.options.write
? WorkerMode.Write
: WorkerMode.Print,
type: MessageType.WorkerInitialization,
} as IInitializationMessage);
}