stream: allow pass stream class to stream.compose

PR-URL: #50187Fixes: #50176
Reviewed-By: Moshe Atlow <moshe@atlow.co.il>
Reviewed-By: Robert Nagy <ronagy@icloud.com>
Reviewed-By: Benjamin Gruenbaum <benjamingr@gmail.com>

Author: himself65

lib/internal/streams/duplexify.js

@@ -85,6 +85,11 @@ module.exports = function duplexify(body, name) {
 if(typeofbody==='function'){
 const{ value, write, final, destroy }=fromAsyncGen(body);
 
+// Body might be a constructor function instead of an async generator function.
+if(isDuplexNodeStream(value)){
+returnvalue;
+}
+
 if(isIterable(value)){
 returnfrom(Duplexify,value,{
 // TODO (ronag): highWaterMark?

test/parallel/test-runner-run.mjs

@@ -104,6 +104,16 @@ describe('require(\'node:test\').run', { concurrency: true }, () => {
 assert.match(stringResults[1],/tests1/);
 assert.match(stringResults[1],/pass1/);
 });
+
+it('spec',async()=>{
+constresult=awaitrun({
+files: [join(testFixtures,'default-behavior/test/random.cjs')]
+}).compose(spec).toArray();
+conststringResults=result.map((bfr)=>bfr.toString());
+assert.match(stringResults[0],/thisshouldpass/);
+assert.match(stringResults[1],/tests1/);
+assert.match(stringResults[1],/pass1/);
+});
 });
 
 it('should be piped with tap',async()=>{