Function main

benchmark/test_runner/test-reporters.js:21–41

({ n, reporter: r })

let testResults;

async function main({ n, reporter: r }) {
  testResults ??= await stream.toArray();

  // Create readable streams for each iteration
  const readables = Array.from({ length: n }, () => Readable.from(testResults));

  // Get the selected reporter
  const reporter = reporters[r];

  bench.start();

  let noDead;
  for (const readable of readables) {
    // Process each readable stream through the reporter
    noDead = await readable.compose(reporter).toArray();
  }

  bench.end(n);

  assert.ok(noDead);
}