Skip to content

Commit 262e654

Browse files
committed
stream: simplify nested PromisePrototypeThens
Signed-off-by: Antoine du Hamel <duhamelantoine1995@gmail.com> PR-URL: #64470 Reviewed-By: René <contact.9a5d6388@renegade334.me.uk> Reviewed-By: Trivikram Kamat <trivikr.dev@gmail.com>
1 parent 71343b2 commit 262e654

1 file changed

Lines changed: 16 additions & 32 deletions

File tree

lib/internal/webstreams/adapters.js

Lines changed: 16 additions & 32 deletions
Original file line numberDiff line numberDiff line change
@@ -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

Comments
 (0)