diff --git a/lib/internal/webstreams/adapters.js b/lib/internal/webstreams/adapters.js index 1ade5d32951ff5..d3f8212f1a135b 100644 --- a/lib/internal/webstreams/adapters.js +++ b/lib/internal/webstreams/adapters.js @@ -335,15 +335,12 @@ function newStreamWritableFromWritableStream(writableStream, options = kEmptyObj } PromisePrototypeThen( - writer.ready, - () => { - return PromisePrototypeThen( - SafePromiseAllReturnVoid( - chunks, - (data) => writer.write(data.chunk)), - done, - done); - }, + PromisePrototypeThen( + writer.ready, + () => SafePromiseAllReturnVoid( + chunks, + (data) => writer.write(data.chunk))), + done, done); }, @@ -372,13 +369,8 @@ function newStreamWritableFromWritableStream(writableStream, options = kEmptyObj } PromisePrototypeThen( - writer.ready, - () => { - return PromisePrototypeThen( - writer.write(chunk), - done, - done); - }, + PromisePrototypeThen(writer.ready, () => writer.write(chunk)), + done, done); }, @@ -801,15 +793,12 @@ function newStreamDuplexFromReadableWritablePair(pair = kEmptyObject, options = } PromisePrototypeThen( - writer.ready, - () => { - return PromisePrototypeThen( - SafePromiseAllReturnVoid( - chunks, - (data) => writer.write(data.chunk)), - done, - done); - }, + PromisePrototypeThen( + writer.ready, + () => SafePromiseAllReturnVoid( + chunks, + (data) => writer.write(data.chunk))), + done, done); }, @@ -838,13 +827,8 @@ function newStreamDuplexFromReadableWritablePair(pair = kEmptyObject, options = } PromisePrototypeThen( - writer.ready, - () => { - return PromisePrototypeThen( - writer.write(chunk), - done, - done); - }, + PromisePrototypeThen(writer.ready, () => writer.write(chunk)), + done, done); },