test: fix test-runner-inspect

PR-URL: #44620Fixes: #44600 Reviewed-By: Benjamin Gruenbaum <[email protected]> Reviewed-By: Antoine du Hamel <[email protected]>

Author: MoLow

lib/internal/test_runner/runner.js

@@ -4,21 +4,19 @@ const{
  ArrayPrototypeFilter,
  ArrayPrototypeIncludes,
  ArrayPrototypeJoin,
- ArrayPrototypePop,
  ArrayPrototypePush,
  ArrayPrototypeSlice,
  ArrayPrototypeSort,
  ObjectAssign,
  PromisePrototypeThen,
- RegExpPrototypeSymbolSplit,
  SafePromiseAll,
  SafeSet,
- StringPrototypeEndsWith,
 }=primordials;
 
-const{ Buffer }=require('buffer');
 const{ spawn }=require('child_process');
 const{ readdirSync, statSync }=require('fs');
+// TODO(aduh95): switch to internal/readline/interface when backporting to Node.js 16.x is no longer a concern.
+const{ createInterface }=require('readline');
 constconsole=require('internal/console/global');
 const{
 codes: {
@@ -114,28 +112,6 @@ function getRunArgs({path, inspectPort }){
 returnargv;
 }
 
-functionmakeStderrCallback(callback){
-if(!isUsingInspector()){
-returncallback;
-}
-letbuffer=Buffer.alloc(0);
-return(data)=>{
-callback(data);
-constnewData=Buffer.concat([buffer,data]);
-conststr=newData.toString('utf8');
-letlines=str;
-if(StringPrototypeEndsWith(lines,'\n')){
-buffer=Buffer.alloc(0);
-}else{
-lines=RegExpPrototypeSymbolSplit(/\r?\n/,str);
-buffer=Buffer.from(ArrayPrototypePop(lines),'utf8');
-lines=ArrayPrototypeJoin(lines,'\n');
-}
-if(isInspectorMessage(lines)){
-process.stderr.write(lines);
-}
-};
-}
 
 functionrunTestFile(path,root,inspectPort){
 constsubtest=root.createSubtest(Test,path,async(t)=>{
@@ -151,9 +127,18 @@ function runTestFile(path, root, inspectPort){
 err=error;
 });
 
-child.stderr.on('data',makeStderrCallback((data)=>{
+child.stderr.on('data',(data)=>{
 stderr+=data;
-}));
+});
+
+if(isUsingInspector()){
+constrl=createInterface({input: child.stderr});
+rl.on('line',(line)=>{
+if(isInspectorMessage(line)){
+process.stderr.write(line+'\n');
+}
+});
+}
 
 const{0: {0: code,1: signal},1: stdout}=awaitSafePromiseAll([
 once(child,'exit',{signal: t.signal}),