diff --git a/README.md b/README.md
index 2ff9fa3..d422753 100644
--- a/README.md
+++ b/README.md
@@ -24,8 +24,7 @@ Differences from the core implementation:
 
 <!-- source_link=lib/test.js -->
 
-The `node:test` module facilitates the creation of JavaScript tests that
-report results in [TAP][] format. This package is a port of `node:test`.
+The `node:test` module facilitates the creation of JavaScript tests.
 To access it:
 
 ```mjs
@@ -99,9 +98,7 @@ test('callback failing test', (t, done) => {
 })
 ```
 
-As a test file executes, TAP is written to the standard output of the Node.js
-process. This output can be interpreted by any test harness that understands
-the TAP format. If any tests fail, the process exit code is set to `1`.
+If any tests fail, the process exit code is set to `1`.
 
 #### Subtests
 
@@ -130,8 +127,7 @@ test to fail.
 ## Skipping tests
 
 Individual tests can be skipped by passing the `skip` option to the test, or by
-calling the test context's `skip()` method. Both of these options support
-including a message that is displayed in the TAP output as shown in the
+calling the test context's `skip()` method as shown in the
 following example.
 
 ```js
@@ -265,7 +261,7 @@ Test name patterns do not change the set of files that the test runner executes.
 
 ## Extraneous asynchronous activity
 
-Once a test function finishes executing, the TAP results are output as quickly
+Once a test function finishes executing, the results are reported as quickly
 as possible while maintaining the order of the tests. However, it is possible
 for the test function to generate asynchronous activity that outlives the test
 itself. The test runner handles this type of activity, but does not delay the
@@ -274,13 +270,13 @@ reporting of test results in order to accommodate it.
 In the following example, a test completes with two `setImmediate()`
 operations still outstanding. The first `setImmediate()` attempts to create a
 new subtest. Because the parent test has already finished and output its
-results, the new subtest is immediately marked as failed, and reported in the
-top level of the file's TAP output.
+results, the new subtest is immediately marked as failed, and reported later
+to the {TestsStream}.
 
 The second `setImmediate()` creates an `uncaughtException` event.
 `uncaughtException` and `unhandledRejection` events originating from a completed
 test are marked as failed by the `test` module and reported as diagnostic
-warnings in the top level of the file's TAP output.
+warnings at the top level by the {TestsStream}.
 
 ```js
 test('a test that creates asynchronous activity', t => {
@@ -431,6 +427,163 @@ test('spies on an object method', (t) => {
 });
 ```
 
+
+## Test reporters
+
+<!-- YAML
+added: REPLACEME
+-->
+
+The `node:test` module supports passing [`--test-reporter`][]
+flags for the test runner to use a specific reporter.
+
+The following built-reporters are supported:
+
+* `tap`
+  The `tap` reporter is the default reporter used by the test runner. It outputs
+  the test results in the [TAP][] format.
+
+* `spec`
+  The `spec` reporter outputs the test results in a human-readable format.
+
+* `dot`
+  The `dot` reporter outputs the test results in a comact format,
+  where each passing test is represented by a `.`,
+  and each failing test is represented by a `X`.
+
+### Custom reporters
+
+[`--test-reporter`][] can be used to specify a path to custom reporter.
+a custom reporter is a module that exports a value
+accepted by [stream.compose][].
+Reporters should transform events emitted by a {TestsStream}
+
+Example of a custom reporter using {stream.Transform}:
+
+```mjs
+import { Transform } from 'node:stream';
+const customReporter = new Transform({
+  writableObjectMode: true,
+  transform(event, encoding, callback) {
+    switch (event.type) {
+      case 'test:start':
+        callback(null, `test ${event.data.name} started`);
+        break;
+      case 'test:pass':
+        callback(null, `test ${event.data.name} passed`);
+        break;
+      case 'test:fail':
+        callback(null, `test ${event.data.name} failed`);
+        break;
+      case 'test:plan':
+        callback(null, 'test plan');
+        break;
+      case 'test:diagnostic':
+        callback(null, event.data.message);
+        break;
+    }
+  },
+});
+export default customReporter;
+```
+
+```cjs
+const { Transform } = require('node:stream');
+const customReporter = new Transform({
+  writableObjectMode: true,
+  transform(event, encoding, callback) {
+    switch (event.type) {
+      case 'test:start':
+        callback(null, `test ${event.data.name} started`);
+        break;
+      case 'test:pass':
+        callback(null, `test ${event.data.name} passed`);
+        break;
+      case 'test:fail':
+        callback(null, `test ${event.data.name} failed`);
+        break;
+      case 'test:plan':
+        callback(null, 'test plan');
+        break;
+      case 'test:diagnostic':
+        callback(null, event.data.message);
+        break;
+    }
+  },
+});
+module.exports = customReporter;
+```
+
+Example of a custom reporter using a generator function:
+
+```mjs
+export default async function * customReporter(source) {
+  for await (const event of source) {
+    switch (event.type) {
+      case 'test:start':
+        yield `test ${event.data.name} started\n`;
+        break;
+      case 'test:pass':
+        yield `test ${event.data.name} passed\n`;
+        break;
+      case 'test:fail':
+        yield `test ${event.data.name} failed\n`;
+        break;
+      case 'test:plan':
+        yield 'test plan';
+        break;
+      case 'test:diagnostic':
+        yield `${event.data.message}\n`;
+        break;
+    }
+  }
+}
+```
+
+```cjs
+module.exports = async function * customReporter(source) {
+  for await (const event of source) {
+    switch (event.type) {
+      case 'test:start':
+        yield `test ${event.data.name} started\n`;
+        break;
+      case 'test:pass':
+        yield `test ${event.data.name} passed\n`;
+        break;
+      case 'test:fail':
+        yield `test ${event.data.name} failed\n`;
+        break;
+      case 'test:plan':
+        yield 'test plan\n';
+        break;
+      case 'test:diagnostic':
+        yield `${event.data.message}\n`;
+        break;
+    }
+  }
+};
+```
+
+### Multiple reporters
+
+The [`--test-reporter`][] flag can be specified multiple times to report test
+results in several formats. In this situation
+it is required to specify a destination for each reporter
+using [`--test-reporter-destination`][].
+Destination can be `stdout`, `stderr`, or a file path.
+Reporters and destinations are paired according
+to the order they were specified.
+
+In the following example, the `spec` reporter will output to `stdout`,
+and the `dot` reporter will output to `file.txt`:
+
+```bash
+node --test-reporter=spec --test-reporter=dot --test-reporter-destination=stdout --test-reporter-destination=file.txt
+```
+
+When a single reporter is specified, the destination will default to `stdout`,
+unless a destination is explicitly provided.
+
 ## `run([options])`
 
 <!-- YAML
@@ -459,7 +612,7 @@ added: REPLACEME
     incremented from the primary's `process.debugPort`.
     **Default:** `undefined`.
     
-* Returns: {TapStream}
+* Returns: {TestsStream}
 
 ```js
 run({ files: [path.resolve('./tests/test.js')] })
@@ -501,12 +654,11 @@ run({ files: [path.resolve('./tests/test.js')] })
 - Returns: {Promise} Resolved with `undefined` once the test completes.
 
 The `test()` function is the value imported from the `test` module. Each
-invocation of this function results in the creation of a test point in the TAP
-output.
+invocation of this function results in reporting the test to the {TestsStream}.
 
 The `TestContext` object passed to the `fn` argument can be used to perform
 actions related to the current test. Examples include skipping the test, adding
-additional TAP diagnostic information, or creating subtests.
+additional diagnostic information, or creating subtests.
 
 `test()` returns a `Promise` that resolves once the test completes. The return
 value can usually be discarded for top level tests. However, the return value
@@ -545,8 +697,7 @@ thus prevent the scheduled cancellation.
 * Returns: `undefined`.
 
 The `describe()` function imported from the `test` module. Each
-invocation of this function results in the creation of a Subtest
-and a test point in the TAP output.
+invocation of this function results in the creation of a Subtest.
 After invocation of top level `describe` functions,
 all top level tests and suites will execute.
 
@@ -572,8 +723,6 @@ Shorthand for marking a suite as `TODO`, same as
 * Returns: `undefined`.
 
 The `it()` function is the value imported from the `test` module.
-Each invocation of this function results in the creation of a test point in the
-TAP output.
 
 ## `it.skip([name][, options][, fn])`
 
@@ -961,7 +1110,7 @@ added: REPLACEME
 This function is syntax sugar for [`MockTracker.method`][] with `options.setter`
 set to `true`.
 
-## Class: `TapStream`
+## Class: `TestsStream`
 
 <!-- YAML
 added: REPLACEME
@@ -969,13 +1118,15 @@ added: REPLACEME
 
 * Extends {ReadableStream}
 
-A successful call to [`run()`][] method will return a new {TapStream}
-object, streaming a [TAP][] output
-`TapStream` will emit events, in the order of the tests definition
+A successful call to [`run()`][] method will return a new {TestsStream}
+object, streaming a series of events representing the execution of the tests.
+`TestsStream` will emit events, in the order of the tests definition
 
 ### Event: `'test:diagnostic'`
 
-* `message` {string} The diagnostic message.
+* `data` {Object}
+  * `message` {string} The diagnostic message.
+  * `nesting` {number} The nesting level of the test.
 
 Emitted when [`context.diagnostic`][] is called.
 
@@ -983,10 +1134,13 @@ Emitted when [`context.diagnostic`][] is called.
 
 * `data` {Object}
   * `details` {Object} Additional execution metadata.
+    * `duration` {number} The duration of the test in milliseconds.
+    * `error` {Error} The error thrown by the test.
   * `name` {string} The test name.
+  * `nesting` {number} The nesting level of the test.
   * `testNumber` {number} The ordinal number of the test.
-  * `todo` {string|undefined} Present if [`context.todo`][] is called
-  * `skip` {string|undefined} Present if [`context.skip`][] is called
+  * `todo` {string|boolean|undefined} Present if [`context.todo`][] is called
+  * `skip` {string|boolean|undefined} Present if [`context.skip`][] is called
 
 Emitted when a test fails.
 
@@ -994,13 +1148,31 @@ Emitted when a test fails.
 
 * `data` {Object}
   * `details` {Object} Additional execution metadata.
+    * `duration` {number} The duration of the test in milliseconds.
   * `name` {string} The test name.
+  * `nesting` {number} The nesting level of the test.
   * `testNumber` {number} The ordinal number of the test.
-  * `todo` {string|undefined} Present if [`context.todo`][] is called
-  * `skip` {string|undefined} Present if [`context.skip`][] is called
+  * `todo` {string|boolean|undefined} Present if [`context.todo`][] is called
+  * `skip` {string|boolean|undefined} Present if [`context.skip`][] is called
 
 Emitted when a test passes.
 
+### Event: `'test:plan'`
+
+* `data` {Object}
+  * `nesting` {number} The nesting level of the test.
+  * `count` {number} The number of subtests that have ran.
+
+Emitted when all subtests have completed for a given test.
+
+### Event: `'test:start'`
+
+* `data` {Object}
+  * `name` {string} The test name.
+  * `nesting` {number} The nesting level of the test.
+
+Emitted when a test starts.
+
 ## Class: `TestContext`
 
 An instance of `TestContext` is passed to each test function in order to
@@ -1092,9 +1264,9 @@ test('top level test', async (t) => {
 
 ### `context.diagnostic(message)`
 
-- `message` {string} Message to be displayed as a TAP diagnostic.
+- `message` {string}Message to be reported.
 
-This function is used to write TAP diagnostics to the output. Any diagnostic
+This function is used to write diagnostics to the output. Any diagnostic
 information is included at the end of the test's results. This function does
 not return a value.
 
@@ -1128,19 +1300,19 @@ test('top level test', async (t) => {
 
 ### `context.skip([message])`
 
-- `message` {string} Optional skip message to be displayed in TAP output.
+* `message` {string} Optional skip message.
 
 This function causes the test's output to indicate the test as skipped. If
-`message` is provided, it is included in the TAP output. Calling `skip()` does
+`message` is provided, it is included in the output. Calling `skip()` does
 not terminate execution of the test function. This function does not return a
 value.
 
 ### `context.todo([message])`
 
-- `message` {string} Optional `TODO` message to be displayed in TAP output.
+* `message` {string} Optional `TODO` message.
 
 This function adds a `TODO` directive to the test's output. If `message` is
-provided, it is included in the TAP output. Calling `todo()` does not terminate
+provided, it is included in the output. Calling `todo()` does not terminate
 execution of the test function. This function does not return a value.
 
 ### `context.test([name][, options][, fn])`
diff --git a/bin/node-core-test.js b/bin/node-core-test.js
index 4bc6e89..e41f837 100755
--- a/bin/node-core-test.js
+++ b/bin/node-core-test.js
@@ -8,15 +8,21 @@ const minimist = require('minimist')
 
 const { argv } = require('#internal/options')
 
+const stringArgs = ['test-name-pattern', 'test-reporter', 'test-reporter-destination']
+
 Object.assign(argv, minimist(process.argv.slice(2), {
   boolean: ['test', 'test-only'],
-  string: ['test-name-pattern'],
+  string: stringArgs,
   default: Object.prototype.hasOwnProperty.call(argv, 'test') ? { test: argv.test } : undefined
 }))
 
-if (typeof argv['test-name-pattern'] === 'string') {
-  argv['test-name-pattern'] = [argv['test-name-pattern']]
-}
+stringArgs.forEach((arg) => {
+  if (typeof argv[arg] === 'string') {
+    argv[arg] = [argv[arg]]
+  } else if (!Array.isArray(argv[arg])) {
+    argv[arg] = []
+  }
+})
 
 process.argv.splice(1, Infinity, ...argv._)
 if (argv.test) {
diff --git a/lib/internal/main/test_runner.js b/lib/internal/main/test_runner.js
index ed7c644..f058df8 100644
--- a/lib/internal/main/test_runner.js
+++ b/lib/internal/main/test_runner.js
@@ -1,10 +1,11 @@
-// https://github.com/nodejs/node/blob/a165193c5c8e4bcfbd12b2c3f6e55a81a251c258/lib/internal/main/test_runner.js
+// https://github.com/nodejs/node/blob/a1b27b25bb01aadd3fd2714e4b136db11b7eb85a/lib/internal/main/test_runner.js
 'use strict'
 const {
   prepareMainThreadExecution
 } = require('#internal/process/pre_execution')
 const { isUsingInspector } = require('#internal/util/inspector')
 const { run } = require('#internal/test_runner/runner')
+const { setupTestReporters } = require('#internal/test_runner/utils')
 
 prepareMainThreadExecution(false)
 // markBootstrapComplete();
@@ -19,8 +20,8 @@ if (isUsingInspector()) {
   inspectPort = process.debugPort
 }
 
-const tapStream = run({ concurrency, inspectPort })
-tapStream.pipe(process.stdout)
-tapStream.once('test:fail', () => {
+const testsStream = run({ concurrency, inspectPort })
+testsStream.once('test:fail', () => {
   process.exitCode = 1
 })
+setupTestReporters(testsStream)
diff --git a/lib/internal/per_context/primordials.js b/lib/internal/per_context/primordials.js
index 2f12a34..7ba5002 100644
--- a/lib/internal/per_context/primordials.js
+++ b/lib/internal/per_context/primordials.js
@@ -2,6 +2,7 @@
 
 const replaceAll = require('string.prototype.replaceall')
 
+exports.hardenRegExp = (re) => re
 exports.ArrayFrom = (it, mapFn) => Array.from(it, mapFn)
 exports.ArrayIsArray = Array.isArray
 exports.ArrayPrototypeConcat = (arr, ...el) => arr.concat(...el)
@@ -51,10 +52,12 @@ exports.PromisePrototypeThen = (promise, thenFn, catchFn) => promise.then(thenFn
 exports.PromiseResolve = val => Promise.resolve(val)
 exports.PromiseRace = val => Promise.race(val)
 exports.Proxy = Proxy
+exports.RegExp = RegExp
 exports.RegExpPrototypeSymbolSplit = (reg, str) => reg[Symbol.split](str)
 exports.SafeArrayIterator = class ArrayIterator {constructor (array) { this.array = array }[Symbol.iterator] () { return this.array.values() }}
 exports.SafeMap = Map
 exports.SafePromiseAll = (array, mapFn) => Promise.all(mapFn ? array.map(mapFn) : array)
+exports.SafePromiseAllReturnArrayLike = (array, mapFn) => Promise.all(mapFn ? array.map(mapFn) : array)
 exports.SafePromiseRace = (array, mapFn) => Promise.race(mapFn ? array.map(mapFn) : array)
 exports.SafeSet = Set
 exports.SafeWeakMap = WeakMap
diff --git a/lib/internal/test_runner/harness.js b/lib/internal/test_runner/harness.js
index 26d35ba..45dd90e 100644
--- a/lib/internal/test_runner/harness.js
+++ b/lib/internal/test_runner/harness.js
@@ -1,4 +1,4 @@
-// https://github.com/nodejs/node/blob/06603c44a5b0e92b1a3591ace467ce9770bf9658/lib/internal/test_runner/harness.js
+// https://github.com/nodejs/node/blob/a1b27b25bb01aadd3fd2714e4b136db11b7eb85a/lib/internal/test_runner/harness.js
 'use strict'
 const {
   ArrayPrototypeForEach,
@@ -17,6 +17,7 @@ const {
 const { kEmptyObject } = require('#internal/util')
 const { getOptionValue } = require('#internal/options')
 const { kCancelledByParent, Test, ItTest, Suite } = require('#internal/test_runner/test')
+const { setupTestReporters } = require('#internal/test_runner/utils')
 const { bigint: hrtime } = process.hrtime
 
 const isTestRunnerCli = getOptionValue('--test')
@@ -110,7 +111,6 @@ function setup (root) {
   }
 
   root.startTime = hrtime()
-  root.reporter.version()
 
   wasRootSetup.add(root)
   return root
@@ -120,10 +120,10 @@ let globalRoot
 function getGlobalRoot () {
   if (!globalRoot) {
     globalRoot = createTestTree()
-    globalRoot.reporter.pipe(process.stdout)
     globalRoot.reporter.once('test:fail', () => {
       process.exitCode = 1
     })
+    setupTestReporters(globalRoot.reporter)
   }
   return globalRoot
 }
diff --git a/lib/internal/test_runner/reporter/dot.js b/lib/internal/test_runner/reporter/dot.js
new file mode 100644
index 0000000..a4ac33b
--- /dev/null
+++ b/lib/internal/test_runner/reporter/dot.js
@@ -0,0 +1,18 @@
+// https://github.com/nodejs/node/blob/a1b27b25bb01aadd3fd2714e4b136db11b7eb85a/lib/test/reporter/dot.js
+'use strict'
+
+module.exports = async function * dot (source) {
+  let count = 0
+  for await (const { type } of source) {
+    if (type === 'test:pass') {
+      yield '.'
+    }
+    if (type === 'test:fail') {
+      yield 'X'
+    }
+    if ((type === 'test:fail' || type === 'test:pass') && ++count % 20 === 0) {
+      yield '\n'
+    }
+  }
+  yield '\n'
+}
diff --git a/lib/internal/test_runner/reporter/spec.js b/lib/internal/test_runner/reporter/spec.js
new file mode 100644
index 0000000..5eb3b17
--- /dev/null
+++ b/lib/internal/test_runner/reporter/spec.js
@@ -0,0 +1,110 @@
+// https://github.com/nodejs/node/blob/a1b27b25bb01aadd3fd2714e4b136db11b7eb85a/lib/test/reporter/spec.js
+'use strict'
+
+const {
+  ArrayPrototypeJoin,
+  ArrayPrototypePop,
+  ArrayPrototypeShift,
+  ArrayPrototypeUnshift,
+  hardenRegExp,
+  RegExpPrototypeSymbolSplit,
+  SafeMap,
+  StringPrototypeRepeat
+} = require('#internal/per_context/primordials')
+const assert = require('assert')
+const Transform = require('stream').Transform
+const { inspectWithNoCustomRetry } = require('#internal/errors')
+const { green, blue, red, white, gray } = require('#internal/util/colors')
+
+const inspectOptions = { __proto__: null, colors: true, breakLength: Infinity }
+
+const colors = {
+  __proto__: null,
+  'test:fail': red,
+  'test:pass': green,
+  'test:diagnostic': blue
+}
+const symbols = {
+  __proto__: null,
+  'test:fail': '\u2716 ',
+  'test:pass': '\u2714 ',
+  'test:diagnostic': '\u2139 ',
+  'arrow:right': '\u25B6 '
+}
+class SpecReporter extends Transform {
+  #stack = []
+  #reported = []
+  #indentMemo = new SafeMap()
+
+  constructor () {
+    super({ writableObjectMode: true })
+  }
+
+  #indent (nesting) {
+    let value = this.#indentMemo.get(nesting)
+    if (value === undefined) {
+      value = StringPrototypeRepeat('  ', nesting)
+      this.#indentMemo.set(nesting, value)
+    }
+
+    return value
+  }
+
+  #formatError (error, indent) {
+    if (!error) return ''
+    const err = error.code === 'ERR_TEST_FAILURE' ? error.cause : error
+    const message = ArrayPrototypeJoin(
+      RegExpPrototypeSymbolSplit(
+        hardenRegExp(/\r?\n/),
+        inspectWithNoCustomRetry(err, inspectOptions)
+      ), `\n${indent}  `)
+    return `\n${indent}  ${message}\n`
+  }
+
+  #handleEvent ({ type, data }) {
+    const color = colors[type] ?? white
+    const symbol = symbols[type] ?? ' '
+
+    switch (type) {
+      case 'test:fail':
+      case 'test:pass': {
+        const subtest = ArrayPrototypeShift(this.#stack) // This is the matching `test:start` event
+        if (subtest) {
+          assert(subtest.type === 'test:start')
+          assert(subtest.data.nesting === data.nesting)
+          assert(subtest.data.name === data.name)
+        }
+        let prefix = ''
+        while (this.#stack.length) {
+          // Report all the parent `test:start` events
+          const parent = ArrayPrototypePop(this.#stack)
+          assert(parent.type === 'test:start')
+          const msg = parent.data
+          ArrayPrototypeUnshift(this.#reported, msg)
+          prefix += `${this.#indent(msg.nesting)}${symbols['arrow:right']}${msg.name}\n`
+        }
+        const indent = this.#indent(data.nesting)
+        const duration_ms = data.details?.duration_ms ? ` ${gray}(${data.details.duration_ms}ms)${white}` : '' // eslint-disable-line camelcase
+        const title = `${data.name}${duration_ms}` // eslint-disable-line camelcase
+        if (this.#reported[0] && this.#reported[0].nesting === data.nesting && this.#reported[0].name === data.name) {
+          // If this test has had children - it was already reporter, so slightly modify the output
+          ArrayPrototypeShift(this.#reported)
+          return `${prefix}${indent}${color}${symbols['arrow:right']}${white}${title}\n\n`
+        }
+        const error = this.#formatError(data.details?.error, indent)
+        return `${prefix}${indent}${color}${symbol}${title}${error}${white}\n`
+      }
+      case 'test:start':
+        ArrayPrototypeUnshift(this.#stack, { __proto__: null, data, type })
+        break
+      case 'test:diagnostic':
+        return `${color}${this.#indent(data.nesting)}${symbol}${data.message}${white}\n`
+    }
+  }
+
+  _transform ({ type, data }, encoding, callback) {
+    callback(null, this.#handleEvent({ type, data }))
+  }
+}
+
+module.exports = SpecReporter
diff --git a/lib/internal/test_runner/tap_stream.js b/lib/internal/test_runner/reporter/tap.js
similarity index 60%
rename from lib/internal/test_runner/tap_stream.js
rename to lib/internal/test_runner/reporter/tap.js
index 97a4918..5923f8e 100644
--- a/lib/internal/test_runner/tap_stream.js
+++ b/lib/internal/test_runner/reporter/tap.js
@@ -1,22 +1,21 @@
-// https://github.com/nodejs/node/blob/232efb06fe8787e9573e298ce7ac293ad23b7684/lib/internal/test_runner/tap_stream.js
+// https://github.com/nodejs/node/blob/a1b27b25bb01aadd3fd2714e4b136db11b7eb85a/lib/internal/test_runner/tap_stream.js
 
 'use strict'
 
 const {
   ArrayPrototypeForEach,
   ArrayPrototypeJoin,
-  ArrayPrototypeMap,
   ArrayPrototypePush,
-  ArrayPrototypeShift,
   ObjectEntries,
+  RegExpPrototypeSymbolReplace,
+  SafeMap,
   StringPrototypeReplaceAll,
-  StringPrototypeToUpperCase,
   StringPrototypeSplit,
-  RegExpPrototypeSymbolReplace
+  StringPrototypeRepeat
 } = require('#internal/per_context/primordials')
 const { inspectWithNoCustomRetry } = require('#internal/errors')
-const Readable = require('#internal/streams/readable')
 const { isError, kEmptyObject } = require('#internal/util')
+const kDefaultIndent = '    ' // 4 spaces
 const kFrameStartRegExp = /^ {4}at /
 const kLineBreakRegExp = /\n|\r\n/
 const kDefaultTAPVersion = 13
@@ -24,111 +23,73 @@ const inspectOptions = { colors: false, breakLength: Infinity }
 let testModule // Lazy loaded due to circular dependency.
 
 function lazyLoadTest () {
-  testModule = testModule ?? require('#internal/test_runner/test')
-
+  testModule ??= require('#internal/test_runner/test')
   return testModule
 }
 
-class TapStream extends Readable {
-  #buffer
-  #canPush
-
-  constructor () {
-    super()
-    this.#buffer = []
-    this.#canPush = true
-  }
-
-  _read () {
-    this.#canPush = true
-
-    while (this.#buffer.length > 0) {
-      const line = ArrayPrototypeShift(this.#buffer)
-
-      if (!this.#tryPush(line)) {
-        return
-      }
+async function * tapReporter (source) {
+  yield `TAP version ${kDefaultTAPVersion}\n`
+  for await (const { type, data } of source) {
+    switch (type) {
+      case 'test:fail':
+        yield reportTest(data.nesting, data.testNumber, 'not ok', data.name, data.skip, data.todo)
+        yield reportDetails(data.nesting, data.details)
+        break
+      case 'test:pass':
+        yield reportTest(data.nesting, data.testNumber, 'ok', data.name, data.skip, data.todo)
+        yield reportDetails(data.nesting, data.details)
+        break
+      case 'test:plan':
+        yield `${indent(data.nesting)}1..${data.count}\n`
+        break
+      case 'test:start':
+        yield `${indent(data.nesting)}# Subtest: ${tapEscape(data.name)}\n`
+        break
+      case 'test:diagnostic':
+        yield `${indent(data.nesting)}# ${tapEscape(data.message)}\n`
+        break
     }
   }
+}
 
-  bail (message) {
-    this.#tryPush(`Bail out!${message ? ` ${tapEscape(message)}` : ''}\n`)
-  }
-
-  fail (indent, testNumber, name, details, directive) {
-    this.emit('test:fail', { __proto__: null, name, testNumber, details, ...directive })
-    this.#test(indent, testNumber, 'not ok', name, directive)
-    this.#details(indent, details)
-  }
-
-  ok (indent, testNumber, name, details, directive) {
-    this.emit('test:pass', { __proto__: null, name, testNumber, details, ...directive })
-    this.#test(indent, testNumber, 'ok', name, directive)
-    this.#details(indent, details)
-  }
-
-  plan (indent, count, explanation) {
-    const exp = `${explanation ? ` # ${tapEscape(explanation)}` : ''}`
-
-    this.#tryPush(`${indent}1..${count}${exp}\n`)
-  }
-
-  getSkip (reason) {
-    return { __proto__: null, skip: reason }
-  }
-
-  getTodo (reason) {
-    return { __proto__: null, todo: reason }
-  }
-
-  subtest (indent, name) {
-    this.#tryPush(`${indent}# Subtest: ${tapEscape(name)}\n`)
-  }
-
-  #details (indent, data = kEmptyObject) {
-    const { error, duration_ms } = data // eslint-disable-line camelcase
-    let details = `${indent}  ---\n`
+function reportTest (nesting, testNumber, status, name, skip, todo) {
+  let line = `${indent(nesting)}${status} ${testNumber}`
 
-    details += jsToYaml(indent, 'duration_ms', duration_ms)
-    details += jsToYaml(indent, null, error)
-    details += `${indent}  ...\n`
-    this.#tryPush(details)
+  if (name) {
+    line += ` ${tapEscape(`- ${name}`)}`
   }
 
-  diagnostic (indent, message) {
-    this.emit('test:diagnostic', message)
-    this.#tryPush(`${indent}# ${tapEscape(message)}\n`)
+  if (skip !== undefined) {
+    line += ` # SKIP${typeof skip === 'string' && skip.length ? ` ${tapEscape(skip)}` : ''}`
+  } else if (todo !== undefined) {
+    line += ` # TODO${typeof todo === 'string' && todo.length ? ` ${tapEscape(todo)}` : ''}`
   }
 
-  version (spec = kDefaultTAPVersion) {
-    this.#tryPush(`TAP version ${spec}\n`)
-  }
+  line += '\n'
 
-  #test (indent, testNumber, status, name, directive = kEmptyObject) {
-    let line = `${indent}${status} ${testNumber}`
-
-    if (name) {
-      line += ` ${tapEscape(`- ${name}`)}`
-    }
+  return line
+}
 
-    line += ArrayPrototypeJoin(ArrayPrototypeMap(ObjectEntries(directive), ({ 0: key, 1: value }) => (
-      ` # ${StringPrototypeToUpperCase(key)}${value ? ` ${tapEscape(value)}` : ''}`
-    )), '')
+function reportDetails (nesting, data = kEmptyObject) {
+  const { error, duration_ms } = data // eslint-disable-line camelcase
+  const _indent = indent(nesting)
+  let details = `${_indent}  ---\n`
 
-    line += '\n'
+  details += jsToYaml(_indent, 'duration_ms', duration_ms)
+  details += jsToYaml(_indent, null, error)
+  details += `${_indent}  ...\n`
+  return details
+}
 
-    this.#tryPush(line)
+const memo = new SafeMap()
+function indent (nesting) {
+  let value = memo.get(nesting)
+  if (value === undefined) {
+    value = StringPrototypeRepeat(kDefaultIndent, nesting)
+    memo.set(nesting, value)
   }
 
-  #tryPush (message) {
-    if (this.#canPush) {
-      this.#canPush = this.push(message)
-    } else {
-      ArrayPrototypePush(this.#buffer, message)
-    }
-
-    return this.#canPush
-  }
+  return value
 }
 
 // In certain places, # and \ need to be escaped as \# and \\.
@@ -269,4 +230,4 @@ function isAssertionLike (value) {
   return value && typeof value === 'object' && 'expected' in value && 'actual' in value
 }
 
-module.exports = { TapStream }
+module.exports = tapReporter
diff --git a/lib/internal/test_runner/runner.js b/lib/internal/test_runner/runner.js
index 42c83c6..7e88470 100644
--- a/lib/internal/test_runner/runner.js
+++ b/lib/internal/test_runner/runner.js
@@ -1,4 +1,4 @@
-// https://github.com/nodejs/node/blob/232efb06fe8787e9573e298ce7ac293ad23b7684/lib/internal/test_runner/runner.js
+// https://github.com/nodejs/node/blob/a1b27b25bb01aadd3fd2714e4b136db11b7eb85a/lib/internal/test_runner/runner.js
 'use strict'
 const {
   ArrayFrom,
@@ -7,12 +7,13 @@ const {
   ArrayPrototypeIncludes,
   ArrayPrototypePush,
   ArrayPrototypeSlice,
+  ArrayPrototypeSome,
   ArrayPrototypeSort,
   ObjectAssign,
   PromisePrototypeThen,
   SafePromiseAll,
   SafeSet,
-  StringPrototypeRepeat
+  StringPrototypeStartsWith
 } = require('#internal/per_context/primordials')
 
 const { spawn } = require('child_process')
@@ -29,9 +30,9 @@ const { validateArray } = require('#internal/validators')
 const { getInspectPort, isUsingInspector, isInspectorMessage } = require('#internal/util/inspector')
 const { kEmptyObject } = require('#internal/util')
 const { createTestTree } = require('#internal/test_runner/harness')
-const { kDefaultIndent, kSubtestsFailed, Test } = require('#internal/test_runner/test')
+const { kSubtestsFailed, Test } = require('#internal/test_runner/test')
 const { TapParser } = require('#internal/test_runner/tap_parser')
-const { YAMLToJs } = require('#internal/test_runner/yaml_parser')
+const { YAMLToJs } = require('#internal/test_runner/yaml_to_js')
 const { TokenKind } = require('#internal/test_runner/tap_lexer')
 const {
   isSupportedFileType,
@@ -41,6 +42,7 @@ const { basename, join, resolve } = require('path')
 const { once } = require('events')
 
 const kFilterArgs = ['--test']
+const kFilterArgValues = ['--test-reporter', '--test-reporter-destination']
 
 // TODO(cjihrig): Replace this with recursive readdir once it lands.
 function processPath (path, testFiles, options) {
@@ -105,8 +107,9 @@ function createTestFileList () {
   return ArrayPrototypeSort(ArrayFrom(testFiles))
 }
 
-function filterExecArgv (arg) {
-  return !ArrayPrototypeIncludes(kFilterArgs, arg)
+function filterExecArgv (arg, i, arr) {
+  return !ArrayPrototypeIncludes(kFilterArgs, arg) &&
+  !ArrayPrototypeSome(kFilterArgValues, (p) => arg === p || (i > 0 && arr[i - 1] === p) || StringPrototypeStartsWith(arg, `${p}=`))
 }
 
 function getRunArgs ({ path, inspectPort }) {
@@ -121,7 +124,7 @@ function getRunArgs ({ path, inspectPort }) {
 class FileTest extends Test {
   #buffer = []
   #handleReportItem ({ kind, node, nesting = 0 }) {
-    const indent = StringPrototypeRepeat(kDefaultIndent, nesting + 1)
+    nesting += 1
 
     switch (kind) {
       case TokenKind.TAP_VERSION:
@@ -130,11 +133,11 @@ class FileTest extends Test {
         break
 
       case TokenKind.TAP_PLAN:
-        this.reporter.plan(indent, node.end - node.start + 1)
+        this.reporter.plan(nesting, node.end - node.start + 1)
         break
 
       case TokenKind.TAP_SUBTEST_POINT:
-        this.reporter.subtest(indent, node.name)
+        this.reporter.start(nesting, node.name)
         break
 
       case TokenKind.TAP_TEST_POINT:
@@ -153,7 +156,7 @@ class FileTest extends Test {
 
         if (pass) {
           this.reporter.ok(
-            indent,
+            nesting,
             node.id,
             node.description,
             YAMLToJs(node.diagnostics),
@@ -161,7 +164,7 @@ class FileTest extends Test {
           )
         } else {
           this.reporter.fail(
-            indent,
+            nesting,
             node.id,
             node.description,
             YAMLToJs(node.diagnostics),
@@ -171,15 +174,15 @@ class FileTest extends Test {
         break
 
       case TokenKind.COMMENT:
-        if (indent === kDefaultIndent) {
+        if (nesting === 1) {
           // Ignore file top level diagnostics
           break
         }
-        this.reporter.diagnostic(indent, node.comment)
+        this.reporter.diagnostic(nesting, node.comment)
         break
 
       case TokenKind.UNKNOWN:
-        this.reporter.diagnostic(indent, node.value)
+        this.reporter.diagnostic(nesting, node.value)
         break
     }
   }
@@ -189,12 +192,12 @@ class FileTest extends Test {
       ArrayPrototypePush(this.#buffer, ast)
       return
     }
-    this.reportSubtest()
+    this.reportStarted()
     this.#handleReportItem(ast)
   }
 
   report () {
-    this.reportSubtest()
+    this.reportStarted()
     ArrayPrototypeForEach(this.#buffer, (ast) => this.#handleReportItem(ast))
     super.report()
   }
diff --git a/lib/internal/test_runner/test.js b/lib/internal/test_runner/test.js
index 10cf1fc..f2e8e41 100644
--- a/lib/internal/test_runner/test.js
+++ b/lib/internal/test_runner/test.js
@@ -1,4 +1,4 @@
-// https://github.com/nodejs/node/blob/385d595a4f1d887f6d4221e6071571132498d57c/lib/internal/test_runner/test.js
+// https://github.com/nodejs/node/blob/a1b27b25bb01aadd3fd2714e4b136db11b7eb85a/lib/internal/test_runner/test.js
 
 'use strict'
 
@@ -36,7 +36,7 @@ const {
 } = require('#internal/errors')
 const { getOptionValue } = require('#internal/options')
 const { MockTracker } = require('#internal/test_runner/mock')
-const { TapStream } = require('#internal/test_runner/tap_stream')
+const { TestsStream } = require('#internal/test_runner/tests_stream')
 const {
   convertStringToRegExp,
   createDeferredCallback,
@@ -65,7 +65,6 @@ const kSubtestsFailed = 'subtestsFailed'
 const kTestCodeFailure = 'testCodeFailure'
 const kTestTimeoutFailure = 'testTimeoutFailure'
 const kHookFailure = 'hookFailed'
-const kDefaultIndent = '    '
 const kDefaultTimeout = null
 const noop = FunctionPrototype
 const isTestRunner = getOptionValue('--test')
@@ -178,19 +177,19 @@ class Test extends AsyncResource {
 
     if (parent === null) {
       this.concurrency = 1
-      this.indent = ''
+      this.nesting = 0
       this.only = testOnlyFlag
-      this.reporter = new TapStream()
+      this.reporter = new TestsStream()
       this.runOnlySubtests = this.only
       this.testNumber = 0
       this.timeout = kDefaultTimeout
     } else {
-      const indent = parent.parent === null
-        ? parent.indent
-        : parent.indent + kDefaultIndent
+      const nesting = parent.parent === null
+        ? parent.nesting
+        : parent.nesting + 1
 
       this.concurrency = parent.concurrency
-      this.indent = indent
+      this.nesting = nesting
       this.only = only ?? !parent.runOnlySubtests
       this.reporter = parent.reporter
       this.runOnlySubtests = !this.only
@@ -322,7 +321,7 @@ class Test extends AsyncResource {
       }
 
       if (i === 1 && this.parent !== null) {
-        this.reportSubtest()
+        this.reportStarted()
       }
 
       // Report the subtest's results and remove it from the ready map.
@@ -621,19 +620,19 @@ class Test extends AsyncResource {
       this.parent.processPendingSubtests()
     } else if (!this.reported) {
       this.reported = true
-      this.reporter.plan(this.indent, this.subtests.length)
+      this.reporter.plan(this.nesting, this.subtests.length)
 
       for (let i = 0; i < this.diagnostics.length; i++) {
-        this.reporter.diagnostic(this.indent, this.diagnostics[i])
+        this.reporter.diagnostic(this.nesting, this.diagnostics[i])
       }
 
-      this.reporter.diagnostic(this.indent, `tests ${this.subtests.length}`)
-      this.reporter.diagnostic(this.indent, `pass ${counters.passed}`)
-      this.reporter.diagnostic(this.indent, `fail ${counters.failed}`)
-      this.reporter.diagnostic(this.indent, `cancelled ${counters.cancelled}`)
-      this.reporter.diagnostic(this.indent, `skipped ${counters.skipped}`)
-      this.reporter.diagnostic(this.indent, `todo ${counters.todo}`)
-      this.reporter.diagnostic(this.indent, `duration_ms ${this.#duration()}`)
+      this.reporter.diagnostic(this.nesting, `tests ${this.subtests.length}`)
+      this.reporter.diagnostic(this.nesting, `pass ${counters.passed}`)
+      this.reporter.diagnostic(this.nesting, `fail ${counters.failed}`)
+      this.reporter.diagnostic(this.nesting, `cancelled ${counters.cancelled}`)
+      this.reporter.diagnostic(this.nesting, `skipped ${counters.skipped}`)
+      this.reporter.diagnostic(this.nesting, `todo ${counters.todo}`)
+      this.reporter.diagnostic(this.nesting, `duration_ms ${this.#duration()}`)
       this.reporter.push(null)
     }
   }
@@ -669,9 +668,9 @@ class Test extends AsyncResource {
 
   report () {
     if (this.subtests.length > 0) {
-      this.reporter.plan(this.subtests[0].indent, this.subtests.length)
+      this.reporter.plan(this.subtests[0].nesting, this.subtests.length)
     } else {
-      this.reportSubtest()
+      this.reportStarted()
     }
     let directive
     const details = { __proto__: null, duration_ms: this.#duration() }
@@ -683,24 +682,24 @@ class Test extends AsyncResource {
     }
 
     if (this.passed) {
-      this.reporter.ok(this.indent, this.testNumber, this.name, details, directive)
+      this.reporter.ok(this.nesting, this.testNumber, this.name, details, directive)
     } else {
       details.error = this.error
-      this.reporter.fail(this.indent, this.testNumber, this.name, details, directive)
+      this.reporter.fail(this.nesting, this.testNumber, this.name, details, directive)
     }
 
     for (let i = 0; i < this.diagnostics.length; i++) {
-      this.reporter.diagnostic(this.indent, this.diagnostics[i])
+      this.reporter.diagnostic(this.nesting, this.diagnostics[i])
     }
   }
 
-  reportSubtest () {
+  reportStarted () {
     if (this.#reportedSubtest || this.parent === null) {
       return
     }
     this.#reportedSubtest = true
-    this.parent.reportSubtest()
-    this.reporter.subtest(this.indent, this.name)
+    this.parent.reportStarted()
+    this.reporter.start(this.nesting, this.name)
   }
 }
 
@@ -807,7 +806,6 @@ class Suite extends Test {
 module.exports = {
   ItTest,
   kCancelledByParent,
-  kDefaultIndent,
   kSubtestsFailed,
   kTestCodeFailure,
   kUnwrapErrors,
diff --git a/lib/internal/test_runner/tests_stream.js b/lib/internal/test_runner/tests_stream.js
new file mode 100644
index 0000000..ef11359
--- /dev/null
+++ b/lib/internal/test_runner/tests_stream.js
@@ -0,0 +1,75 @@
+// https://github.com/nodejs/node/blob/a1b27b25bb01aadd3fd2714e4b136db11b7eb85a/lib/internal/test_runner/tests_stream.js
+'use strict'
+const {
+  ArrayPrototypePush,
+  ArrayPrototypeShift
+} = require('#internal/per_context/primordials')
+const Readable = require('#internal/streams/readable')
+
+class TestsStream extends Readable {
+  #buffer
+  #canPush
+
+  constructor () {
+    super({ objectMode: true })
+    this.#buffer = []
+    this.#canPush = true
+  }
+
+  _read () {
+    this.#canPush = true
+
+    while (this.#buffer.length > 0) {
+      const obj = ArrayPrototypeShift(this.#buffer)
+
+      if (!this.#tryPush(obj)) {
+        return
+      }
+    }
+  }
+
+  fail (nesting, testNumber, name, details, directive) {
+    this.#emit('test:fail', { __proto__: null, name, nesting, testNumber, details, ...directive })
+  }
+
+  ok (nesting, testNumber, name, details, directive) {
+    this.#emit('test:pass', { __proto__: null, name, nesting, testNumber, details, ...directive })
+  }
+
+  plan (nesting, count) {
+    this.#emit('test:plan', { __proto__: null, nesting, count })
+  }
+
+  getSkip (reason = undefined) {
+    return { __proto__: null, skip: reason ?? true }
+  }
+
+  getTodo (reason = undefined) {
+    return { __proto__: null, todo: reason ?? true }
+  }
+
+  start (nesting, name) {
+    this.#emit('test:start', { __proto__: null, nesting, name })
+  }
+
+  diagnostic (nesting, message) {
+    this.#emit('test:diagnostic', { __proto__: null, nesting, message })
+  }
+
+  #emit (type, data) {
+    this.emit(type, data)
+    this.#tryPush({ type, data })
+  }
+
+  #tryPush (message) {
+    if (this.#canPush) {
+      this.#canPush = this.push(message)
+    } else {
+      ArrayPrototypePush(this.#buffer, message)
+    }
+
+    return this.#canPush
+  }
+}
+
+module.exports = { TestsStream }
diff --git a/lib/internal/test_runner/utils.js b/lib/internal/test_runner/utils.js
index c2919d8..ef1cc3b 100644
--- a/lib/internal/test_runner/utils.js
+++ b/lib/internal/test_runner/utils.js
@@ -1,8 +1,18 @@
-// https://github.com/nodejs/node/blob/87170c3f9271da947a7b33d0696ec4cf8aab6eb6/lib/internal/test_runner/utils.js
+// https://github.com/nodejs/node/blob/a1b27b25bb01aadd3fd2714e4b136db11b7eb85a/lib/internal/test_runner/utils.js
 'use strict'
-const { RegExpPrototypeExec } = require('#internal/per_context/primordials')
+const {
+  ArrayPrototypePush,
+  ObjectGetOwnPropertyDescriptor,
+  SafePromiseAllReturnArrayLike,
+  RegExp,
+  RegExpPrototypeExec,
+  SafeMap
+} = require('#internal/per_context/primordials')
 const { basename } = require('path')
+const { createWriteStream } = require('fs')
 const { createDeferredPromise } = require('#internal/util')
+const { getOptionValue } = require('#internal/options')
+
 const {
   codes: {
     ERR_INVALID_ARG_VALUE,
@@ -10,6 +20,7 @@ const {
   },
   kIsNodeError
 } = require('#internal/errors')
+const { compose } = require('stream')
 
 const kMultipleCallbackInvocations = 'multipleCallbackInvocations'
 const kRegExpPattern = /^\/(.*)\/([a-z]*)$/
@@ -75,10 +86,70 @@ function convertStringToRegExp (str, name) {
   }
 }
 
+const kBuiltinDestinations = new SafeMap([
+  ['stdout', process.stdout],
+  ['stderr', process.stderr]
+])
+
+const kBuiltinReporters = new SafeMap([
+  ['spec', '#internal/test_runner/reporter/spec'],
+  ['dot', '#internal/test_runner/reporter/dot'],
+  ['tap', '#internal/test_runner/reporter/tap']
+])
+
+const kDefaultReporter = 'tap'
+const kDefaultDestination = 'stdout'
+
+async function getReportersMap (reporters, destinations) {
+  return SafePromiseAllReturnArrayLike(reporters, async (name, i) => {
+    const destination = kBuiltinDestinations.get(destinations[i]) ?? createWriteStream(destinations[i])
+    let reporter = await import(kBuiltinReporters.get(name) ?? name)
+
+    if (reporter?.default) {
+      reporter = reporter.default
+    }
+
+    if (reporter?.prototype && ObjectGetOwnPropertyDescriptor(reporter.prototype, 'constructor')) {
+      reporter = new reporter() // eslint-disable-line new-cap
+    }
+
+    if (!reporter) {
+      throw new ERR_INVALID_ARG_VALUE('Reporter', name, 'is not a valid reporter')
+    }
+
+    return { __proto__: null, reporter, destination }
+  })
+}
+
+async function setupTestReporters (testsStream) {
+  const destinations = getOptionValue('--test-reporter-destination') ?? []
+  const reporters = getOptionValue('--test-reporter') ?? []
+
+  if (reporters.length === 0 && destinations.length === 0) {
+    ArrayPrototypePush(reporters, kDefaultReporter)
+  }
+
+  if (reporters.length === 1 && destinations.length === 0) {
+    ArrayPrototypePush(destinations, kDefaultDestination)
+  }
+
+  if (destinations.length !== reporters.length) {
+    throw new ERR_INVALID_ARG_VALUE('--test-reporter', reporters,
+      'must match the number of specified \'--test-reporter-destination\'')
+  }
+
+  const reportersMap = await getReportersMap(reporters, destinations)
+  for (let i = 0; i < reportersMap.length; i++) {
+    const { reporter, destination } = reportersMap[i]
+    compose(testsStream, reporter).pipe(destination)
+  }
+}
+
 module.exports = {
   convertStringToRegExp,
   createDeferredCallback,
   doesPathMatchFilter,
   isSupportedFileType,
-  isTestFailureError
+  isTestFailureError,
+  setupTestReporters
 }
diff --git a/lib/internal/test_runner/yaml_parser.js b/lib/internal/test_runner/yaml_to_js.js
similarity index 96%
rename from lib/internal/test_runner/yaml_parser.js
rename to lib/internal/test_runner/yaml_to_js.js
index 2e85db8..399b915 100644
--- a/lib/internal/test_runner/yaml_parser.js
+++ b/lib/internal/test_runner/yaml_to_js.js
@@ -1,4 +1,4 @@
-// https://github.com/nodejs/node/blob/232efb06fe8787e9573e298ce7ac293ad23b7684/lib/internal/test_runner/yaml_parser.js
+// https://github.com/nodejs/node/blob/a1b27b25bb01aadd3fd2714e4b136db11b7eb85a/lib/internal/test_runner/yaml_parser.js
 'use strict'
 const {
   codes: {
diff --git a/lib/internal/util/colors.js b/lib/internal/util/colors.js
new file mode 100644
index 0000000..d44f2c1
--- /dev/null
+++ b/lib/internal/util/colors.js
@@ -0,0 +1,26 @@
+// https://github.com/nodejs/node/blob/a1b27b25bb01aadd3fd2714e4b136db11b7eb85a/lib/internal/util/colors.js
+'use strict'
+
+module.exports = {
+  blue: '',
+  green: '',
+  white: '',
+  red: '',
+  gray: '',
+  clear: '',
+  hasColors: false,
+  refresh () {
+    if (process.stderr.isTTY) {
+      const hasColors = process.stderr.hasColors()
+      module.exports.blue = hasColors ? '\u001b[34m' : ''
+      module.exports.green = hasColors ? '\u001b[32m' : ''
+      module.exports.white = hasColors ? '\u001b[39m' : ''
+      module.exports.red = hasColors ? '\u001b[31m' : ''
+      module.exports.gray = hasColors ? '\u001b[90m' : ''
+      module.exports.clear = hasColors ? '\u001bc' : ''
+      module.exports.hasColors = hasColors
+    }
+  }
+}
+
+module.exports.refresh()
diff --git a/test/fixtures/test-runner/custom_reporters/custom.cjs b/test/fixtures/test-runner/custom_reporters/custom.cjs
new file mode 100644
index 0000000..5d32723
--- /dev/null
+++ b/test/fixtures/test-runner/custom_reporters/custom.cjs
@@ -0,0 +1,18 @@
+// https://github.com/nodejs/node/blob/a1b27b25bb01aadd3fd2714e4b136db11b7eb85a/test/fixtures/test-runner/custom_reporters/custom.cjs
+const { Transform } = require('node:stream')
+
+const customReporter = new Transform({
+  writableObjectMode: true,
+  transform (event, encoding, callback) {
+    this.counters ??= {}
+    this.counters[event.type] = (this.counters[event.type] ?? 0) + 1
+    callback()
+  },
+  flush (callback) {
+    this.push('custom.cjs ')
+    this.push(JSON.stringify(this.counters))
+    callback()
+  }
+})
+
+module.exports = customReporter
diff --git a/test/fixtures/test-runner/custom_reporters/custom.js b/test/fixtures/test-runner/custom_reporters/custom.js
new file mode 100644
index 0000000..a84c4b8
--- /dev/null
+++ b/test/fixtures/test-runner/custom_reporters/custom.js
@@ -0,0 +1,9 @@
+// https://github.com/nodejs/node/blob/a1b27b25bb01aadd3fd2714e4b136db11b7eb85a/test/fixtures/test-runner/custom_reporters/custom.js
+module.exports = async function * customReporter (source) {
+  const counters = {}
+  for await (const event of source) {
+    counters[event.type] = (counters[event.type] ?? 0) + 1
+  }
+  yield 'custom.js '
+  yield JSON.stringify(counters)
+}
diff --git a/test/fixtures/test-runner/custom_reporters/custom.mjs b/test/fixtures/test-runner/custom_reporters/custom.mjs
new file mode 100644
index 0000000..17e6869
--- /dev/null
+++ b/test/fixtures/test-runner/custom_reporters/custom.mjs
@@ -0,0 +1,9 @@
+// https://github.com/nodejs/node/blob/a1b27b25bb01aadd3fd2714e4b136db11b7eb85a/test/fixtures/test-runner/custom_reporters/custom.mjs
+export default async function * customReporter (source) {
+  const counters = {}
+  for await (const event of source) {
+    counters[event.type] = (counters[event.type] ?? 0) + 1
+  }
+  yield 'custom.mjs '
+  yield JSON.stringify(counters)
+}
diff --git a/test/fixtures/test-runner/reporters.js b/test/fixtures/test-runner/reporters.js
new file mode 100644
index 0000000..a6c216d
--- /dev/null
+++ b/test/fixtures/test-runner/reporters.js
@@ -0,0 +1,12 @@
+// https://github.com/nodejs/node/blob/a1b27b25bb01aadd3fd2714e4b136db11b7eb85a/test/fixtures/test-runner/reporters.js
+'use strict'
+const test = require('#node:test')
+
+test('nested', { concurrency: 4 }, async (t) => {
+  t.test('ok', () => {})
+  t.test('failing', () => {
+    throw new Error('error')
+  })
+})
+
+test('top level', () => {})
diff --git a/test/message.js b/test/message.js
index b2b6234..edd0e52 100755
--- a/test/message.js
+++ b/test/message.js
@@ -13,7 +13,7 @@ const binPath = resolve(__dirname, '..', bin.test)
 const MESSAGE_FOLDER = join(__dirname, './message/')
 const WAIT_FOR_ELLIPSIS = Symbol('wait for ellispis')
 
-const TEST_RUNNER_FLAGS = ['--test', '--test-only', '--test-name-pattern']
+const TEST_RUNNER_FLAGS = ['--test', '--test-only', '--test-name-pattern', '--test-reporter', '--test-reporter-destination']
 
 function readLines (file) {
   return createInterface({
@@ -69,7 +69,7 @@ async function IsFailureOutput (self, output) {
     let regex
     if (patterns[i] === WAIT_FOR_ELLIPSIS) {
       waitingForEllipsis = true
-    } else if (!(regex = new RegExp(patterns[i])).test(outlines[i]) && !regex.test(outlines[i].trimEnd())) {
+    } else if (!(regex = new RegExp(patterns[i])).test(outlines[i].replace(/\r/, '')) && !regex.test(outlines[i].replace(/\r/, '').trimEnd())) {
       if (waitingForEllipsis) {
         patterns.splice(i, 0, WAIT_FOR_ELLIPSIS)
         continue
diff --git a/test/message/test_runner_desctibe_it.out b/test/message/test_runner_desctibe_it.out
index ec9337e..208097d 100644
--- a/test/message/test_runner_desctibe_it.out
+++ b/test/message/test_runner_desctibe_it.out
@@ -24,7 +24,6 @@ not ok 3 - sync fail todo # TODO
     *
     *
     *
-    *
   ...
 # Subtest: sync fail todo with message
 not ok 4 - sync fail todo with message # TODO this is a failing todo
@@ -41,7 +40,6 @@ not ok 4 - sync fail todo with message # TODO this is a failing todo
     *
     *
     *
-    *
   ...
 # Subtest: sync skip pass
 ok 5 - sync skip pass # SKIP
@@ -73,7 +71,6 @@ not ok 8 - sync throw fail
     *
     *
     *
-    *
   ...
 # Subtest: async skip pass
 ok 9 - async skip pass # SKIP
@@ -100,7 +97,6 @@ not ok 11 - async throw fail
     *
     *
     *
-    *
   ...
 # Subtest: async skip fail
 not ok 12 - async skip fail
@@ -132,7 +128,6 @@ not ok 13 - async assertion fail
     *
     *
     *
-    *
   ...
 # Subtest: resolve pass
 ok 14 - resolve pass
@@ -154,7 +149,6 @@ not ok 15 - reject fail
     *
     *
     *
-    *
   ...
 # Subtest: unhandled rejection - passes but warns
 ok 16 - unhandled rejection - passes but warns
@@ -626,7 +620,6 @@ not ok 58 - rejected thenable
   code: 'ERR_TEST_FAILURE'
   stack: |-
     *
-    *
   ...
 # Subtest: invalid subtest fail
 not ok 59 - invalid subtest fail
diff --git a/test/message/test_runner_hooks.out b/test/message/test_runner_hooks.out
index 6bb1705..7c82e9f 100644
--- a/test/message/test_runner_hooks.out
+++ b/test/message/test_runner_hooks.out
@@ -64,7 +64,6 @@ not ok 2 - before throws
     *
     *
     *
-    *
   ...
 # Subtest: after throws
     # Subtest: 1
@@ -93,7 +92,6 @@ not ok 3 - after throws
     *
     *
     *
-    *
   ...
 # Subtest: beforeEach throws
     # Subtest: 1
@@ -490,7 +488,6 @@ not ok 13 - t.after() is called if test body throws
     *
     *
     *
-    *
   ...
 # - after() called
 1..13
diff --git a/test/message/test_runner_output.js b/test/message/test_runner_output.js
index a85c16e..44d5141 100644
--- a/test/message/test_runner_output.js
+++ b/test/message/test_runner_output.js
@@ -1,4 +1,4 @@
-// https://github.com/nodejs/node/blob/22dc987fde29734c5bcbb7c33da20d184ff61627/test/message/test_runner_output.js
+// https://github.com/nodejs/node/blob/a1b27b25bb01aadd3fd2714e4b136db11b7eb85a/test/message/test_runner_output.js
 // Flags: --no-warnings
 'use strict'
 require('../common')
@@ -114,7 +114,7 @@ test('level 0a', { concurrency: 4 }, async (t) => {
     const p1a = new Promise((resolve) => {
       setTimeout(() => {
         resolve()
-      }, 1000)
+      }, 100)
     })
 
     return p1a
@@ -132,7 +132,7 @@ test('level 0a', { concurrency: 4 }, async (t) => {
     const p1c = new Promise((resolve) => {
       setTimeout(() => {
         resolve()
-      }, 2000)
+      }, 200)
     })
 
     return p1c
@@ -142,7 +142,7 @@ test('level 0a', { concurrency: 4 }, async (t) => {
     const p1c = new Promise((resolve) => {
       setTimeout(() => {
         resolve()
-      }, 1500)
+      }, 150)
     })
 
     return p1c
@@ -151,7 +151,7 @@ test('level 0a', { concurrency: 4 }, async (t) => {
   const p0a = new Promise((resolve) => {
     setTimeout(() => {
       resolve()
-    }, 3000)
+    }, 300)
   })
 
   return p0a
@@ -160,7 +160,7 @@ test('level 0a', { concurrency: 4 }, async (t) => {
 test('top level', { concurrency: 2 }, async (t) => {
   t.test('+long running', async (t) => {
     return new Promise((resolve, reject) => {
-      setTimeout(resolve, 3000).unref()
+      setTimeout(resolve, 300).unref()
     })
   })
 
@@ -332,12 +332,12 @@ test('subtest sync throw fails', async (t) => {
 
 test('timed out async test', { timeout: 5 }, async (t) => {
   return new Promise((resolve) => {
-    setTimeout(resolve, 1000)
+    setTimeout(resolve, 100)
   })
 })
 
 test('timed out callback test', { timeout: 5 }, (t, done) => {
-  setTimeout(done, 1000)
+  setTimeout(done, 100)
 })
 
 test('large timeout async test is ok', { timeout: 30_000_000 }, async (t) => {
diff --git a/test/message/test_runner_output.out b/test/message/test_runner_output.out
index 14479c7..42eae97 100644
--- a/test/message/test_runner_output.out
+++ b/test/message/test_runner_output.out
@@ -24,7 +24,6 @@ not ok 3 - sync fail todo # TODO
     *
     *
     *
-    *
   ...
 # Subtest: sync fail todo with message
 not ok 4 - sync fail todo with message # TODO this is a failing todo
@@ -41,7 +40,6 @@ not ok 4 - sync fail todo with message # TODO this is a failing todo
     *
     *
     *
-    *
   ...
 # Subtest: sync skip pass
 ok 5 - sync skip pass # SKIP
@@ -74,7 +72,6 @@ not ok 8 - sync throw fail
     *
     *
     *
-    *
   ...
 # Subtest: async skip pass
 ok 9 - async skip pass # SKIP
@@ -101,7 +98,6 @@ not ok 11 - async throw fail
     *
     *
     *
-    *
   ...
 # Subtest: async skip fail
 not ok 12 - async skip fail # SKIP
@@ -118,7 +114,6 @@ not ok 12 - async skip fail # SKIP
     *
     *
     *
-    *
   ...
 # Subtest: async assertion fail
 not ok 13 - async assertion fail
@@ -142,7 +137,6 @@ not ok 13 - async assertion fail
     *
     *
     *
-    *
   ...
 # Subtest: resolve pass
 ok 14 - resolve pass
@@ -164,7 +158,6 @@ not ok 15 - reject fail
     *
     *
     *
-    *
   ...
 # Subtest: unhandled rejection - passes but warns
 ok 16 - unhandled rejection - passes but warns
diff --git a/test/message/test_runner_output_cli.js b/test/message/test_runner_output_cli.js
new file mode 100644
index 0000000..ab37ddf
--- /dev/null
+++ b/test/message/test_runner_output_cli.js
@@ -0,0 +1,8 @@
+// https://github.com/nodejs/node/blob/a1b27b25bb01aadd3fd2714e4b136db11b7eb85a/test/message/test_runner_output_cli.js
+// Flags: --no-warnings
+'use strict'
+require('../common')
+const spawn = require('node:child_process').spawn
+spawn(process.execPath,
+  ['--no-warnings', '--test', '--test-reporter', 'tap', 'test/message/test_runner_output.js'],
+  { stdio: 'inherit' })
diff --git a/test/message/test_runner_output_cli.out b/test/message/test_runner_output_cli.out
new file mode 100644
index 0000000..f2acdd9
--- /dev/null
+++ b/test/message/test_runner_output_cli.out
@@ -0,0 +1,647 @@
+TAP version 13
+# Subtest: *test_runner_output.js
+    # Subtest: sync pass todo
+    ok 1 - sync pass todo # TODO
+      ---
+      duration_ms: *
+      ...
+    # Subtest: sync pass todo with message
+    ok 2 - sync pass todo with message # TODO this is a passing todo
+      ---
+      duration_ms: *
+      ...
+    # Subtest: sync fail todo
+    not ok 3 - sync fail todo # TODO
+      ---
+      duration_ms: *
+      failureType: 'testCodeFailure'
+      error: 'thrown from sync fail todo'
+      code: 'ERR_TEST_FAILURE'
+      stack: |-
+        *
+        *
+        *
+        *
+        *
+        *
+        *
+      ...
+    # Subtest: sync fail todo with message
+    not ok 4 - sync fail todo with message # TODO this is a failing todo
+      ---
+      duration_ms: *
+      failureType: 'testCodeFailure'
+      error: 'thrown from sync fail todo with message'
+      code: 'ERR_TEST_FAILURE'
+      stack: |-
+        *
+        *
+        *
+        *
+        *
+        *
+        *
+      ...
+    # Subtest: sync skip pass
+    ok 5 - sync skip pass # SKIP
+      ---
+      duration_ms: *
+      ...
+    # Subtest: sync skip pass with message
+    ok 6 - sync skip pass with message # SKIP this is skipped
+      ---
+      duration_ms: *
+      ...
+    # Subtest: sync pass
+    ok 7 - sync pass
+      ---
+      duration_ms: *
+      ...
+    # Subtest: sync throw fail
+    not ok 8 - sync throw fail
+      ---
+      duration_ms: *
+      failureType: 'testCodeFailure'
+      error: 'thrown from sync throw fail'
+      code: 'ERR_TEST_FAILURE'
+      stack: |-
+        *
+        *
+        *
+        *
+        *
+        *
+        *
+      ...
+    # Subtest: async skip pass
+    ok 9 - async skip pass # SKIP
+      ---
+      duration_ms: *
+      ...
+    # Subtest: async pass
+    ok 10 - async pass
+      ---
+      duration_ms: *
+      ...
+    # Subtest: async throw fail
+    not ok 11 - async throw fail
+      ---
+      duration_ms: *
+      failureType: 'testCodeFailure'
+      error: 'thrown from async throw fail'
+      code: 'ERR_TEST_FAILURE'
+      stack: |-
+        *
+        *
+        *
+        *
+        *
+        *
+        *
+      ...
+    # Subtest: async skip fail
+    not ok 12 - async skip fail # SKIP
+      ---
+      duration_ms: *
+      failureType: 'testCodeFailure'
+      error: 'thrown from async throw fail'
+      code: 'ERR_TEST_FAILURE'
+      stack: |-
+        *
+        *
+        *
+        *
+        *
+        *
+        *
+      ...
+    # Subtest: async assertion fail
+    not ok 13 - async assertion fail
+      ---
+      duration_ms: *
+      failureType: 'testCodeFailure'
+      error: |-
+        Expected values to be strictly equal:
+        
+        true !== false
+        
+      code: 'ERR_ASSERTION'
+      expected: false
+      actual: true
+      operator: 'strictEqual'
+      stack: |-
+        *
+        *
+        *
+        *
+        *
+        *
+        *
+      ...
+    # Subtest: resolve pass
+    ok 14 - resolve pass
+      ---
+      duration_ms: *
+      ...
+    # Subtest: reject fail
+    not ok 15 - reject fail
+      ---
+      duration_ms: *
+      failureType: 'testCodeFailure'
+      error: 'rejected from reject fail'
+      code: 'ERR_TEST_FAILURE'
+      stack: |-
+        *
+        *
+        *
+        *
+        *
+        *
+        *
+      ...
+    # Subtest: unhandled rejection - passes but warns
+    ok 16 - unhandled rejection - passes but warns
+      ---
+      duration_ms: *
+      ...
+    # Subtest: async unhandled rejection - passes but warns
+    ok 17 - async unhandled rejection - passes but warns
+      ---
+      duration_ms: *
+      ...
+    # Subtest: immediate throw - passes but warns
+    ok 18 - immediate throw - passes but warns
+      ---
+      duration_ms: *
+      ...
+    # Subtest: immediate reject - passes but warns
+    ok 19 - immediate reject - passes but warns
+      ---
+      duration_ms: *
+      ...
+    # Subtest: immediate resolve pass
+    ok 20 - immediate resolve pass
+      ---
+      duration_ms: *
+      ...
+    # Subtest: subtest sync throw fail
+        # Subtest: +sync throw fail
+        not ok 1 - +sync throw fail
+          ---
+          duration_ms: *
+          failureType: 'testCodeFailure'
+          error: 'thrown from subtest sync throw fail'
+          code: 'ERR_TEST_FAILURE'
+          stack: |-
+            *
+            *
+            *
+            *
+            *
+            *
+            *
+            *
+            *
+            *
+          ...
+        1..1
+    not ok 21 - subtest sync throw fail
+      ---
+      duration_ms: *
+      failureType: 'subtestsFailed'
+      error: '1 subtest failed'
+      code: 'ERR_TEST_FAILURE'
+      ...
+    # Subtest: sync throw non-error fail
+    not ok 22 - sync throw non-error fail
+      ---
+      duration_ms: *
+      failureType: 'testCodeFailure'
+      error: 'Symbol(thrown symbol from sync throw non-error fail)'
+      code: 'ERR_TEST_FAILURE'
+      ...
+    # Subtest: level 0a
+        # Subtest: level 1a
+        ok 1 - level 1a
+          ---
+          duration_ms: *
+          ...
+        # Subtest: level 1b
+        ok 2 - level 1b
+          ---
+          duration_ms: *
+          ...
+        # Subtest: level 1c
+        ok 3 - level 1c
+          ---
+          duration_ms: *
+          ...
+        # Subtest: level 1d
+        ok 4 - level 1d
+          ---
+          duration_ms: *
+          ...
+        1..4
+    ok 23 - level 0a
+      ---
+      duration_ms: *
+      ...
+    # Subtest: top level
+        # Subtest: +long running
+        not ok 1 - +long running
+          ---
+          duration_ms: *
+          failureType: 'cancelledByParent'
+          error: 'test did not finish before its parent and was cancelled'
+          code: 'ERR_TEST_FAILURE'
+          ...
+        # Subtest: +short running
+            # Subtest: ++short running
+            ok 1 - ++short running
+              ---
+              duration_ms: *
+              ...
+            1..1
+        ok 2 - +short running
+          ---
+          duration_ms: *
+          ...
+        1..2
+    not ok 24 - top level
+      ---
+      duration_ms: *
+      failureType: 'subtestsFailed'
+      error: '1 subtest failed'
+      code: 'ERR_TEST_FAILURE'
+      ...
+    # Subtest: invalid subtest - pass but subtest fails
+    ok 25 - invalid subtest - pass but subtest fails
+      ---
+      duration_ms: *
+      ...
+    # Subtest: sync skip option
+    ok 26 - sync skip option # SKIP
+      ---
+      duration_ms: *
+      ...
+    # Subtest: sync skip option with message
+    ok 27 - sync skip option with message # SKIP this is skipped
+      ---
+      duration_ms: *
+      ...
+    # Subtest: sync skip option is false fail
+    not ok 28 - sync skip option is false fail
+      ---
+      duration_ms: *
+      failureType: 'testCodeFailure'
+      error: 'this should be executed'
+      code: 'ERR_TEST_FAILURE'
+      stack: |-
+        *
+        *
+        *
+        *
+        *
+        *
+        *
+      ...
+    # Subtest: <anonymous>
+    ok 29 - <anonymous>
+      ---
+      duration_ms: *
+      ...
+    # Subtest: functionOnly
+    ok 30 - functionOnly
+      ---
+      duration_ms: *
+      ...
+    # Subtest: <anonymous>
+    ok 31 - <anonymous>
+      ---
+      duration_ms: *
+      ...
+    # Subtest: test with only a name provided
+    ok 32 - test with only a name provided
+      ---
+      duration_ms: *
+      ...
+    # Subtest: <anonymous>
+    ok 33 - <anonymous>
+      ---
+      duration_ms: *
+      ...
+    # Subtest: <anonymous>
+    ok 34 - <anonymous> # SKIP
+      ---
+      duration_ms: *
+      ...
+    # Subtest: test with a name and options provided
+    ok 35 - test with a name and options provided # SKIP
+      ---
+      duration_ms: *
+      ...
+    # Subtest: functionAndOptions
+    ok 36 - functionAndOptions # SKIP
+      ---
+      duration_ms: *
+      ...
+    # Subtest: escaped description \\ \# \\\#\\ n \\t f \\v b \\r
+    ok 37 - escaped description \\ \# \\\#\\ n \\t f \\v b \\r
+      ---
+      duration_ms: *
+      ...
+    # Subtest: escaped skip message
+    ok 38 - escaped skip message # SKIP \#skip
+      ---
+      duration_ms: *
+      ...
+    # Subtest: escaped todo message
+    ok 39 - escaped todo message # TODO \#todo
+      ---
+      duration_ms: *
+      ...
+    # Subtest: escaped diagnostic
+    ok 40 - escaped diagnostic
+      ---
+      duration_ms: *
+      ...
+    # Subtest: callback pass
+    ok 41 - callback pass
+      ---
+      duration_ms: *
+      ...
+    # Subtest: callback fail
+    not ok 42 - callback fail
+      ---
+      duration_ms: *
+      failureType: 'testCodeFailure'
+      error: 'callback failure'
+      code: 'ERR_TEST_FAILURE'
+      stack: |-
+        *
+        *
+      ...
+    # Subtest: sync t is this in test
+    ok 43 - sync t is this in test
+      ---
+      duration_ms: *
+      ...
+    # Subtest: async t is this in test
+    ok 44 - async t is this in test
+      ---
+      duration_ms: *
+      ...
+    # Subtest: callback t is this in test
+    ok 45 - callback t is this in test
+      ---
+      duration_ms: *
+      ...
+    # Subtest: callback also returns a Promise
+    not ok 46 - callback also returns a Promise
+      ---
+      duration_ms: *
+      failureType: 'callbackAndPromisePresent'
+      error: 'passed a callback but also returned a Promise'
+      code: 'ERR_TEST_FAILURE'
+      ...
+    # Subtest: callback throw
+    not ok 47 - callback throw
+      ---
+      duration_ms: *
+      failureType: 'testCodeFailure'
+      error: 'thrown from callback throw'
+      code: 'ERR_TEST_FAILURE'
+      stack: |-
+        *
+        *
+        *
+        *
+        *
+        *
+        *
+      ...
+    # Subtest: callback called twice
+    not ok 48 - callback called twice
+      ---
+      duration_ms: *
+      failureType: 'multipleCallbackInvocations'
+      error: 'callback invoked multiple times'
+      code: 'ERR_TEST_FAILURE'
+      stack: |-
+        *
+        *
+      ...
+    # Subtest: callback called twice in different ticks
+    ok 49 - callback called twice in different ticks
+      ---
+      duration_ms: *
+      ...
+    # Subtest: callback called twice in future tick
+    not ok 50 - callback called twice in future tick
+      ---
+      duration_ms: *
+      failureType: 'uncaughtException'
+      error: 'callback invoked multiple times'
+      code: 'ERR_TEST_FAILURE'
+      stack: |-
+        *
+      ...
+    # Subtest: callback async throw
+    not ok 51 - callback async throw
+      ---
+      duration_ms: *
+      failureType: 'uncaughtException'
+      error: 'thrown from callback async throw'
+      code: 'ERR_TEST_FAILURE'
+      stack: |-
+        *
+        *
+      ...
+    # Subtest: callback async throw after done
+    ok 52 - callback async throw after done
+      ---
+      duration_ms: *
+      ...
+    # Subtest: only is set but not in only mode
+        # Subtest: running subtest 1
+        ok 1 - running subtest 1
+          ---
+          duration_ms: *
+          ...
+        # Subtest: running subtest 2
+        ok 2 - running subtest 2
+          ---
+          duration_ms: *
+          ...
+        # Subtest: running subtest 3
+        ok 3 - running subtest 3
+          ---
+          duration_ms: *
+          ...
+        # Subtest: running subtest 4
+        ok 4 - running subtest 4
+          ---
+          duration_ms: *
+          ...
+        1..4
+    ok 53 - only is set but not in only mode
+      ---
+      duration_ms: *
+      ...
+    # Subtest: custom inspect symbol fail
+    not ok 54 - custom inspect symbol fail
+      ---
+      duration_ms: *
+      failureType: 'testCodeFailure'
+      error: 'customized'
+      code: 'ERR_TEST_FAILURE'
+      ...
+    # Subtest: custom inspect symbol that throws fail
+    not ok 55 - custom inspect symbol that throws fail
+      ---
+      duration_ms: *
+      failureType: 'testCodeFailure'
+      error: |-
+        {
+          foo: 1,
+          [Symbol(nodejs.util.inspect.custom)]: [Function: [nodejs.util.inspect.custom]]
+        }
+      code: 'ERR_TEST_FAILURE'
+      ...
+    # Subtest: subtest sync throw fails
+        # Subtest: sync throw fails at first
+        not ok 1 - sync throw fails at first
+          ---
+          duration_ms: *
+          failureType: 'testCodeFailure'
+          error: 'thrown from subtest sync throw fails at first'
+          code: 'ERR_TEST_FAILURE'
+          stack: |-
+            *
+            *
+            *
+            *
+            *
+            *
+            *
+            *
+            *
+            *
+          ...
+        # Subtest: sync throw fails at second
+        not ok 2 - sync throw fails at second
+          ---
+          duration_ms: *
+          failureType: 'testCodeFailure'
+          error: 'thrown from subtest sync throw fails at second'
+          code: 'ERR_TEST_FAILURE'
+          stack: |-
+            *
+            *
+            *
+            *
+            *
+            *
+            *
+            *
+            *
+            *
+          ...
+        1..2
+    not ok 56 - subtest sync throw fails
+      ---
+      duration_ms: *
+      failureType: 'subtestsFailed'
+      error: '2 subtests failed'
+      code: 'ERR_TEST_FAILURE'
+      ...
+    # Subtest: timed out async test
+    not ok 57 - timed out async test
+      ---
+      duration_ms: *
+      failureType: 'testTimeoutFailure'
+      error: 'test timed out after 5ms'
+      code: 'ERR_TEST_FAILURE'
+      ...
+    # Subtest: timed out callback test
+    not ok 58 - timed out callback test
+      ---
+      duration_ms: *
+      failureType: 'testTimeoutFailure'
+      error: 'test timed out after 5ms'
+      code: 'ERR_TEST_FAILURE'
+      ...
+    # Subtest: large timeout async test is ok
+    ok 59 - large timeout async test is ok
+      ---
+      duration_ms: *
+      ...
+    # Subtest: large timeout callback test is ok
+    ok 60 - large timeout callback test is ok
+      ---
+      duration_ms: *
+      ...
+    # Subtest: successful thenable
+    ok 61 - successful thenable
+      ---
+      duration_ms: *
+      ...
+    # Subtest: rejected thenable
+    not ok 62 - rejected thenable
+      ---
+      duration_ms: *
+      failureType: 'testCodeFailure'
+      error: 'custom error'
+      code: 'ERR_TEST_FAILURE'
+      ...
+    # Subtest: unfinished test with uncaughtException
+    not ok 63 - unfinished test with uncaughtException
+      ---
+      duration_ms: *
+      failureType: 'uncaughtException'
+      error: 'foo'
+      code: 'ERR_TEST_FAILURE'
+      stack: |-
+        *
+        *
+        *
+      ...
+    # Subtest: unfinished test with unhandledRejection
+    not ok 64 - unfinished test with unhandledRejection
+      ---
+      duration_ms: *
+      failureType: 'unhandledRejection'
+      error: 'bar'
+      code: 'ERR_TEST_FAILURE'
+      stack: |-
+        *
+        *
+        *
+      ...
+    # Subtest: invalid subtest fail
+    not ok 65 - invalid subtest fail
+      ---
+      duration_ms: *
+      failureType: 'parentAlreadyFinished'
+      error: 'test could not be started because its parent finished'
+      code: 'ERR_TEST_FAILURE'
+      stack: |-
+        *
+      ...
+    1..65
+not ok 1 - *test_runner_output.js
+  ---
+  duration_ms: *
+  failureType: 'subtestsFailed'
+  exitCode: 1
+  error: 'test failed'
+  code: *
+  ...
+1..1
+# tests 1
+# pass 0
+# fail 1
+# cancelled 0
+# skipped 0
+# todo 0
+# duration_ms *
diff --git a/test/message/test_runner_output_dot_reporter.js b/test/message/test_runner_output_dot_reporter.js
new file mode 100644
index 0000000..3ece578
--- /dev/null
+++ b/test/message/test_runner_output_dot_reporter.js
@@ -0,0 +1,7 @@
+// https://github.com/nodejs/node/blob/a1b27b25bb01aadd3fd2714e4b136db11b7eb85a/test/message/test_runner_output_dot_reporter.js
+// Flags: --no-warnings
+'use strict'
+require('../common')
+const spawn = require('node:child_process').spawn
+spawn(process.execPath,
+  ['--no-warnings', '--test-reporter', 'dot', 'test/message/test_runner_output.js'], { stdio: 'inherit' })
diff --git a/test/message/test_runner_output_dot_reporter.out b/test/message/test_runner_output_dot_reporter.out
new file mode 100644
index 0000000..823ecfb
--- /dev/null
+++ b/test/message/test_runner_output_dot_reporter.out
@@ -0,0 +1,4 @@
+..XX...X..XXX.X.....
+XXX.....X..X...X....
+.........X...XXX.XX.
+.....XXXXXXX...XXXX
diff --git a/test/message/test_runner_output_spec_reporter.js b/test/message/test_runner_output_spec_reporter.js
new file mode 100644
index 0000000..9373622
--- /dev/null
+++ b/test/message/test_runner_output_spec_reporter.js
@@ -0,0 +1,11 @@
+// https://github.com/nodejs/node/blob/a1b27b25bb01aadd3fd2714e4b136db11b7eb85a/test/message/test_runner_output_spec_reporter.js
+// Flags: --no-warnings
+'use strict'
+require('../common')
+const spawn = require('node:child_process').spawn
+const child = spawn(process.execPath,
+  ['--no-warnings', '--test-reporter', 'spec', 'test/message/test_runner_output.js'],
+  { stdio: 'pipe' })
+// eslint-disable-next-line no-control-regex
+child.stdout.on('data', (d) => process.stdout.write(d.toString().replace(/[^\x00-\x7F]/g, '').replace(/\u001b\[\d+m/g, '')))
+child.stderr.pipe(process.stderr)
diff --git a/test/message/test_runner_output_spec_reporter.out b/test/message/test_runner_output_spec_reporter.out
new file mode 100644
index 0000000..2d032cb
--- /dev/null
+++ b/test/message/test_runner_output_spec_reporter.out
@@ -0,0 +1,260 @@
+sync pass todo (*ms)
+ sync pass todo with message (*ms)
+ sync fail todo (*ms)
+  Error: thrown from sync fail todo
+  *
+  *
+  *
+  *
+  *
+  *
+  *
+  *
+ sync fail todo with message (*ms)
+  Error: thrown from sync fail todo with message
+  *
+  *
+  *
+  *
+  *
+  *
+  *
+  *
+ sync skip pass (*ms)
+ sync skip pass with message (*ms)
+ sync pass (*ms)
+ this test should pass
+ sync throw fail (*ms)
+  Error: thrown from sync throw fail
+  *
+  *
+  *
+  *
+  *
+  *
+  *
+  *
+ async skip pass (*ms)
+ async pass (*ms)
+ async throw fail (*ms)
+  Error: thrown from async throw fail
+  *
+  *
+  *
+  *
+  *
+  *
+  *
+  *
+ async skip fail (*ms)
+  Error: thrown from async throw fail
+  *
+  *
+  *
+  *
+  *
+  *
+  *
+  *
+ async assertion fail (*ms)
+  AssertionError [ERR_ASSERTION]: Expected values to be strictly equal:
+  
+  true !== false
+  
+  *
+  *
+  *
+  *
+  *
+  *
+  *
+  * {
+    generatedMessage: true,
+    code: 'ERR_ASSERTION',
+    actual: true,
+    expected: false,
+    operator: 'strictEqual'
+  }
+ resolve pass (*ms)
+ reject fail (*ms)
+  Error: rejected from reject fail
+  *
+  *
+  *
+  *
+  *
+  *
+  *
+  *
+ unhandled rejection - passes but warns (*ms)
+ async unhandled rejection - passes but warns (*ms)
+ immediate throw - passes but warns (*ms)
+ immediate reject - passes but warns (*ms)
+ immediate resolve pass (*ms)
+ subtest sync throw fail
+   +sync throw fail (*ms)
+    Error: thrown from subtest sync throw fail
+    *
+    *
+    *
+    *
+    *
+    *
+    *
+    *
+    *
+    *
+   this subtest should make its parent test fail
+ subtest sync throw fail (*ms)
+ sync throw non-error fail (*ms)
+  Symbol(thrown symbol from sync throw non-error fail)
+ level 0a
+   level 1a (*ms)
+   level 1b (*ms)
+   level 1c (*ms)
+   level 1d (*ms)
+ level 0a (*ms)
+ top level
+   +long running (*ms)
+    'test did not finish before its parent and was cancelled'
+   +short running
+     ++short running (*ms)
+   +short running (*ms)
+ top level (*ms)
+ invalid subtest - pass but subtest fails (*ms)
+ sync skip option (*ms)
+ sync skip option with message (*ms)
+ sync skip option is false fail (*ms)
+  Error: this should be executed
+  *
+  *
+  *
+  *
+  *
+  *
+  *
+  *
+ <anonymous> (*ms)
+ functionOnly (*ms)
+ <anonymous> (*ms)
+ test with only a name provided (*ms)
+ <anonymous> (*ms)
+ <anonymous> (*ms)
+ test with a name and options provided (*ms)
+ functionAndOptions (*ms)
+ escaped description \ # *
+ 	     (*ms)
+ escaped skip message (*ms)
+ escaped todo message (*ms)
+ escaped diagnostic (*ms)
+ #diagnostic
+ callback pass (*ms)
+ callback fail (*ms)
+  Error: callback failure
+  *
+  *
+ sync t is this in test (*ms)
+ async t is this in test (*ms)
+ callback t is this in test (*ms)
+ callback also returns a Promise (*ms)
+  'passed a callback but also returned a Promise'
+ callback throw (*ms)
+  Error: thrown from callback throw
+  *
+  *
+  *
+  *
+  *
+  *
+  *
+  *
+ callback called twice (*ms)
+  'callback invoked multiple times'
+ callback called twice in different ticks (*ms)
+ callback called twice in future tick (*ms)
+  Error: callback invoked multiple times
+  *
+  *
+  *
+  *
+  *
+  *
+    failureType: 'multipleCallbackInvocations',
+    cause: 'callback invoked multiple times',
+    code: 'ERR_TEST_FAILURE'
+  }
+ callback async throw (*ms)
+  Error: thrown from callback async throw
+  *
+  *
+ callback async throw after done (*ms)
+ only is set but not in only mode
+   running subtest 1 (*ms)
+   running subtest 2 (*ms)
+   running subtest 3 (*ms)
+   running subtest 4 (*ms)
+ only is set but not in only mode (*ms)
+ custom inspect symbol fail (*ms)
+  customized
+ custom inspect symbol that throws fail (*ms)
+  { foo: 1, [Symbol(nodejs.util.inspect.custom)]: [Function: [nodejs.util.inspect.custom]] }
+ subtest sync throw fails
+   sync throw fails at first (*ms)
+    Error: thrown from subtest sync throw fails at first
+    *
+    *
+    *
+    *
+    *
+    *
+    *
+    *
+    *
+    *
+   sync throw fails at second (*ms)
+    Error: thrown from subtest sync throw fails at second
+    *
+    *
+    *
+    *
+    *
+    *
+    *
+    *
+    *
+    *
+ subtest sync throw fails (*ms)
+ timed out async test (*ms)
+  'test timed out after *ms'
+ timed out callback test (*ms)
+  'test timed out after *ms'
+ large timeout async test is ok (*ms)
+ large timeout callback test is ok (*ms)
+ successful thenable (*ms)
+ rejected thenable (*ms)
+  'custom error'
+ unfinished test with uncaughtException (*ms)
+  Error: foo
+  *
+  *
+  *
+ unfinished test with unhandledRejection (*ms)
+  Error: bar
+  *
+  *
+  *
+ invalid subtest fail (*ms)
+  'test could not be started because its parent finished'
+ Warning: Test "unhandled rejection - passes but warns" generated asynchronous activity after the test ended. This activity created the error "Error: rejected from unhandled rejection fail" and would have caused the test to fail, but instead triggered an unhandledRejection event.
+ Warning: Test "async unhandled rejection - passes but warns" generated asynchronous activity after the test ended. This activity created the error "Error: rejected from async unhandled rejection fail" and would have caused the test to fail, but instead triggered an unhandledRejection event.
+ Warning: Test "immediate throw - passes but warns" generated asynchronous activity after the test ended. This activity created the error "Error: thrown from immediate throw fail" and would have caused the test to fail, but instead triggered an uncaughtException event.
+ Warning: Test "immediate reject - passes but warns" generated asynchronous activity after the test ended. This activity created the error "Error: rejected from immediate reject fail" and would have caused the test to fail, but instead triggered an unhandledRejection event.
+ Warning: Test "callback called twice in different ticks" generated asynchronous activity after the test ended. This activity created the error "Error [ERR_TEST_FAILURE]: callback invoked multiple times" and would have caused the test to fail, but instead triggered an uncaughtException event.
+ Warning: Test "callback async throw after done" generated asynchronous activity after the test ended. This activity created the error "Error: thrown from callback async throw after done" and would have caused the test to fail, but instead triggered an uncaughtException event.
+ tests 65
+ pass 27
+ fail 21
+ cancelled 2
+ skipped 10
+ todo 5
+ duration_ms *
diff --git a/test/parallel/test-runner-cli.js b/test/parallel/test-runner-cli.js
index 397ea82..3487b1e 100644
--- a/test/parallel/test-runner-cli.js
+++ b/test/parallel/test-runner-cli.js
@@ -165,6 +165,4 @@ const testFixtures = fixtures.path('test-runner')
   assert.match(stdout, / {6}error: 'level 0b error'/)
   assert.match(stdout, /not ok 3 - .+nested\.js/)
   assert.match(stdout, /# tests 3/)
-  assert.match(stdout, /# pass 2/)
-  assert.match(stdout, /# fail 1/)
 }
diff --git a/test/parallel/test-runner-exit-code.js b/test/parallel/test-runner-exit-code.js
index 014d381..8ac1a17 100644
--- a/test/parallel/test-runner-exit-code.js
+++ b/test/parallel/test-runner-exit-code.js
@@ -1,4 +1,4 @@
-// https://github.com/nodejs/node/blob/26e27424ad91c60a44d3d4c58b62a39b555ba75d/test/parallel/test-runner-exit-code.js
+// https://github.com/nodejs/node/blob/a1b27b25bb01aadd3fd2714e4b136db11b7eb85a/test/parallel/test-runner-exit-code.js
 'use strict'
 const common = require('../common')
 const fixtures = require('../common/fixtures')
@@ -21,8 +21,7 @@ async function runAndKill (file) {
   })
   const [code, signal] = await once(child, 'exit')
   await finished(child.stdout)
-  assert.match(stdout, /not ok 1/)
-  assert.match(stdout, /# cancelled 1\n/)
+  assert.strictEqual(stdout, 'TAP version 13\n')
   assert.strictEqual(signal, null)
   assert.strictEqual(code, 1)
 }
diff --git a/test/parallel/test-runner-reporters.js b/test/parallel/test-runner-reporters.js
new file mode 100644
index 0000000..dc4cb79
--- /dev/null
+++ b/test/parallel/test-runner-reporters.js
@@ -0,0 +1,96 @@
+// https://github.com/nodejs/node/blob/a1b27b25bb01aadd3fd2714e4b136db11b7eb85a/test/parallel/test-runner-reporters.js
+'use strict'
+
+require('../common')
+const fixtures = require('../common/fixtures')
+const tmpdir = require('../common/tmpdir')
+const { describe, it } = require('#node:test')
+const { spawnSync } = require('node:child_process')
+const assert = require('node:assert')
+const path = require('node:path')
+const fs = require('node:fs')
+
+const testFile = fixtures.path('test-runner/reporters.js')
+tmpdir.refresh()
+
+let tmpFiles = 0
+describe('node:test reporters', { concurrency: true }, () => {
+  it('should default to outputing TAP to stdout', async () => {
+    const child = spawnSync(process.execPath, ['--test', testFile])
+    assert.strictEqual(child.stderr.toString(), '')
+    assert.match(child.stdout.toString(), /TAP version 13/)
+    assert.match(child.stdout.toString(), /ok 1 - ok/)
+    assert.match(child.stdout.toString(), /not ok 2 - failing/)
+    assert.match(child.stdout.toString(), /ok 2 - top level/)
+  })
+
+  it('should default destination to stdout when passing a single reporter', async () => {
+    const child = spawnSync(process.execPath, ['--test', '--test-reporter', 'dot', testFile])
+    assert.strictEqual(child.stderr.toString(), '')
+    assert.strictEqual(child.stdout.toString(), '.XX.X\n')
+  })
+
+  it('should throw when passing reporters without a destination', async () => {
+    const child = spawnSync(process.execPath, ['--test', '--test-reporter', 'dot', '--test-reporter', 'tap', testFile])
+    assert.match(child.stderr.toString(), /The argument '--test-reporter' must match the number of specified '--test-reporter-destination'\./)
+    assert.strictEqual(child.stdout.toString(), '')
+  })
+
+  it('should throw when passing a destination without a reporter', async () => {
+    const child = spawnSync(process.execPath, ['--test', '--test-reporter-destination', 'tap', testFile])
+    assert.match(child.stderr.toString(), /The argument '--test-reporter' must match the number of specified '--test-reporter-destination'\./)
+    assert.strictEqual(child.stdout.toString(), '')
+  })
+
+  it('should support stdout as a destination', async () => {
+    const child = spawnSync(process.execPath,
+      ['--test', '--test-reporter', 'dot', '--test-reporter-destination', 'stdout', testFile])
+    assert.strictEqual(child.stderr.toString(), '')
+    assert.strictEqual(child.stdout.toString(), '.XX.X\n')
+  })
+
+  it('should support stderr as a destination', async () => {
+    const child = spawnSync(process.execPath,
+      ['--test', '--test-reporter', 'dot', '--test-reporter-destination', 'stderr', testFile])
+    assert.strictEqual(child.stderr.toString(), '.XX.X\n')
+    assert.strictEqual(child.stdout.toString(), '')
+  })
+
+  it('should support a file as a destination', async () => {
+    const file = path.join(tmpdir.path, `${tmpFiles++}.out`)
+    const child = spawnSync(process.execPath,
+      ['--test', '--test-reporter', 'dot', '--test-reporter-destination', file, testFile])
+    assert.strictEqual(child.stderr.toString(), '')
+    assert.strictEqual(child.stdout.toString(), '')
+    assert.strictEqual(fs.readFileSync(file, 'utf8'), '.XX.X\n')
+  })
+
+  it('should support multiple reporters', async () => {
+    const file = path.join(tmpdir.path, `${tmpFiles++}.out`)
+    const file2 = path.join(tmpdir.path, `${tmpFiles++}.out`)
+    const child = spawnSync(process.execPath,
+      ['--test',
+        '--test-reporter', 'dot', '--test-reporter-destination', file,
+        '--test-reporter', 'spec', '--test-reporter-destination', file2,
+        '--test-reporter', 'tap', '--test-reporter-destination', 'stdout',
+        testFile])
+    assert.match(child.stdout.toString(), /TAP version 13/)
+    assert.match(child.stdout.toString(), /# duration_ms/)
+    assert.strictEqual(fs.readFileSync(file, 'utf8'), '.XX.X\n')
+    const file2Contents = fs.readFileSync(file2, 'utf8')
+    assert.match(file2Contents, /▶ nested/)
+    assert.match(file2Contents, /✔ ok/)
+    assert.match(file2Contents, /✖ failing/)
+  });
+
+  ['js', 'cjs', 'mjs'].forEach((ext) => {
+    it(`should support a '${ext}' file as a custom reporter`, async () => {
+      const filename = `custom.${ext}`
+      const child = spawnSync(process.execPath,
+        ['--test', '--test-reporter', fixtures.path('test-runner/custom_reporters/', filename),
+          testFile])
+      assert.strictEqual(child.stderr.toString(), '')
+      assert.strictEqual(child.stdout.toString(), `${filename} {"test:start":5,"test:pass":2,"test:fail":3,"test:plan":3,"test:diagnostic":7}`)
+    })
+  })
+})
diff --git a/test/parallel/test-runner-run.mjs b/test/parallel/test-runner-run.mjs
index b41dd33..5f4a126 100644
--- a/test/parallel/test-runner-run.mjs
+++ b/test/parallel/test-runner-run.mjs
@@ -1,4 +1,4 @@
-// https://github.com/nodejs/node/blob/f8ce9117b19702487eb600493d941f7876e00e01/test/parallel/test-runner-run.mjs
+// https://github.com/nodejs/node/blob/a1b27b25bb01aadd3fd2714e4b136db11b7eb85a/test/parallel/test-runner-run.mjs
 
 import common from '../common/index.js'
 import fixtures from '../common/fixtures.js'
@@ -13,7 +13,6 @@ const testFixtures = fixtures.path('test-runner')
 describe('require(\'node:test\').run', { concurrency: true }, () => {
   it('should run with no tests', async () => {
     const stream = run({ files: [] })
-    stream.setEncoding('utf8')
     stream.on('test:fail', common.mustNotCall())
     stream.on('test:pass', common.mustNotCall())
     // eslint-disable-next-line no-unused-vars