stream: simplify pipeline

Backport-PR-URL: #32174 PR-URL: #31316 Reviewed-By: Anna Henningsen <[email protected]> Reviewed-By: Matteo Collina <[email protected]> Reviewed-By: Rich Trott <[email protected]> Reviewed-By: Minwoo Jung <[email protected]>

Author: ronag

lib/internal/streams/pipeline.js

@@ -97,39 +97,19 @@ function makeAsyncIterable(val){
 returnval;
 }elseif(isReadable(val)){
 // Legacy streams are not Iterable.
-return_fromReadable(val);
+returnfromReadable(val);
 }else{
 thrownewERR_INVALID_ARG_TYPE(
 'val',['Readable','Iterable','AsyncIterable'],val);
 }
 }
 
-asyncfunction*_fromReadable(val){
+asyncfunction*fromReadable(val){
 if(!createReadableStreamAsyncIterator){
 createReadableStreamAsyncIterator=
 require('internal/streams/async_iterator');
 }
-
-try{
-if(typeofval.read!=='function'){
-// createReadableStreamAsyncIterator does not support
-// v1 streams. Convert it into a v2 stream.
-
-if(!PassThrough){
-PassThrough=require('_stream_passthrough');
-}
-
-constpt=newPassThrough();
-val
-.on('error',(err)=>pt.destroy(err))
-.pipe(pt);
-yield*createReadableStreamAsyncIterator(pt);
-}else{
-yield*createReadableStreamAsyncIterator(val);
-}
-}finally{
-destroyStream(val);
-}
+yield*createReadableStreamAsyncIterator(val);
 }
 
 asyncfunctionpump(iterable,writable,finish){