Function startWorker

benchmark/src/benchmark.ts:92–124

()

}

function startWorker() {
  return new Promise<{worker: ChildProcess; url: string}>((resolve, reject) => {
    const lines: string[] = [];
    const child = fork(require.resolve('./worker'), [], {
      execArgv: ['--expose-gc'],
      stdio: ['pipe', 'pipe', process.stderr, 'ipc'],
    });

    child.once('error', reject);

    child.on('message', msg => {
      // eslint-disable-next-line @typescript-eslint/no-explicit-any
      const url = (msg as any).url;
      debug('Worker setup done, url is', url);
      resolve({worker: child, url});
    });

    child.once('exit', (code, signal) => {
      const msg = [
        `Child exited with code ${code} signal ${signal}.`,
        ...lines,
      ].join('\n');
      reject(new Error(msg));
    });

    const reader = byline.createStream(child.stdout as Readable);
    reader.on('data', line => {
      const str = line.toString();
      debug('[worker] %s', str);
      lines.push(str);
    });
  });
}

async function closeWorker(worker: ChildProcess) {
  worker.kill();