chore: use readable-stream

nodejs · Feb 8, 2023 · aeaeb73 · aeaeb73
1 parent 9fa496b
commit aeaeb73
Show file tree

Hide file tree

Showing 8 changed files with 168 additions and 52 deletions.
diff --git a/lib/internal/streams/end-of-stream.js b/lib/internal/streams/end-of-stream.js
diff --git a/lib/internal/streams/operators.js b/lib/internal/streams/operators.js
diff --git a/lib/internal/streams/readable.js b/lib/internal/streams/readable.js
diff --git a/lib/internal/test_runner/runner.js b/lib/internal/test_runner/runner.js
@@ -24,7 +24,7 @@ const {
     ERR_TEST_FAILURE
   }
 } = require('#internal/errors')
-const { toArray } = require('#internal/streams/operators').promiseReturningOperators
+const { toArray } = require('readable-stream/lib/internal/streams/operators').promiseReturningOperators
 const { validateArray } = require('#internal/validators')
 const { getInspectPort, isUsingInspector, isInspectorMessage } = require('#internal/util/inspector')
 const { kEmptyObject } = require('#internal/util')

diff --git a/lib/internal/test_runner/tap_stream.js b/lib/internal/test_runner/tap_stream.js
@@ -15,7 +15,7 @@ const {
   RegExpPrototypeSymbolReplace
 } = require('#internal/per_context/primordials')
 const { inspectWithNoCustomRetry } = require('#internal/errors')
-const Readable = require('#internal/streams/readable')
+const { Readable } = require('readable-stream')
 const { isError, kEmptyObject } = require('#internal/util')
 const kFrameStartRegExp = /^ {4}at /
 const kLineBreakRegExp = /\n|\r\n/

diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -28,6 +28,7 @@
   },
   "dependencies": {
     "minimist": "^1.2.6",
+    "readable-stream": "^4.3.0",
     "string.prototype.replaceall": "^1.0.6"
   }
 }
diff --git a/test/parallel/test-runner-tap-parser-stream.js b/test/parallel/test-runner-tap-parser-stream.js
@@ -5,7 +5,7 @@ const common = require('../common')
 const assert = require('node:assert')
 const { TapParser } = require('#internal/test_runner/tap_parser')
 const { TapChecker } = require('#internal/test_runner/tap_checker')
-const { toArray } = require('#internal/streams/operators').promiseReturningOperators
+const { toArray } = require('readable-stream/lib/internal/streams/operators').promiseReturningOperators
 
 const cases = [
   {