Function runWriteSucceed

test/sequential/test-watch-mode-worker.mjs:39–88

({
  file,
  watchedFile,
  watchFlag = '--watch',
  args = [file],
  completed = 'Completed running',
  restarts = 2,
  options = {},
  shouldFail = false,
})

}

async function runWriteSucceed({
  file,
  watchedFile,
  watchFlag = '--watch',
  args = [file],
  completed = 'Completed running',
  restarts = 2,
  options = {},
  shouldFail = false,
}) {
  args.unshift('--no-warnings');
  if (watchFlag !== null) args.unshift(watchFlag);

  const child = spawn(execPath, args, { encoding: 'utf8', stdio: 'pipe', ...options });

  let completes = 0;
  let cancelRestarts = () => {};
  let stderr = '';
  const stdout = [];

  child.stderr.on('data', (data) => {
    stderr += data;
  });

  try {
    for await (const data of createInterface({ input: child.stdout })) {
      if (!data.startsWith('Waiting for graceful termination') &&
          !data.startsWith('Gracefully restarted')) {
        stdout.push(data);
      }

      if (data.startsWith(completed)) {
        completes++;

        if (completes === restarts) break;

        if (completes === 1) {
          cancelRestarts = restart(watchedFile);
        }
      }

      if (!shouldFail && data.startsWith('Failed running')) break;
    }
  } finally {
    child.kill();
    cancelRestarts();
  }

  return { stdout, stderr, pid: child.pid };
}

tmpdir.refresh();