@@ -334,15 +334,12 @@ function newStreamWritableFromWritableStream(writableStream, options = kEmptyObj
334334 }
335335
336336 PromisePrototypeThen (
337- writer . ready ,
338- ( ) => {
339- return PromisePrototypeThen (
340- SafePromiseAllReturnVoid (
341- chunks ,
342- ( data ) => writer . write ( data . chunk ) ) ,
343- done ,
344- done ) ;
345- } ,
337+ PromisePrototypeThen (
338+ writer . ready ,
339+ ( ) => SafePromiseAllReturnVoid (
340+ chunks ,
341+ ( data ) => writer . write ( data . chunk ) ) ) ,
342+ done ,
346343 done ) ;
347344 } ,
348345
@@ -371,13 +368,8 @@ function newStreamWritableFromWritableStream(writableStream, options = kEmptyObj
371368 }
372369
373370 PromisePrototypeThen (
374- writer . ready ,
375- ( ) => {
376- return PromisePrototypeThen (
377- writer . write ( chunk ) ,
378- done ,
379- done ) ;
380- } ,
371+ PromisePrototypeThen ( writer . ready , ( ) => writer . write ( chunk ) ) ,
372+ done ,
381373 done ) ;
382374 } ,
383375
@@ -789,15 +781,12 @@ function newStreamDuplexFromReadableWritablePair(pair = kEmptyObject, options =
789781 }
790782
791783 PromisePrototypeThen (
792- writer . ready ,
793- ( ) => {
794- return PromisePrototypeThen (
795- SafePromiseAllReturnVoid (
796- chunks ,
797- ( data ) => writer . write ( data . chunk ) ) ,
798- done ,
799- done ) ;
800- } ,
784+ PromisePrototypeThen (
785+ writer . ready ,
786+ ( ) => SafePromiseAllReturnVoid (
787+ chunks ,
788+ ( data ) => writer . write ( data . chunk ) ) ) ,
789+ done ,
801790 done ) ;
802791 } ,
803792
@@ -826,13 +815,8 @@ function newStreamDuplexFromReadableWritablePair(pair = kEmptyObject, options =
826815 }
827816
828817 PromisePrototypeThen (
829- writer . ready ,
830- ( ) => {
831- return PromisePrototypeThen (
832- writer . write ( chunk ) ,
833- done ,
834- done ) ;
835- } ,
818+ PromisePrototypeThen ( writer . ready , ( ) => writer . write ( chunk ) ) ,
819+ done ,
836820 done ) ;
837821 } ,
838822
0 commit comments