Commit 262e654
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
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -334,15 +334,12 @@ function newStreamWritableFromWritableStream(writableStream, options = kEmptyObj | |||
| 334 | 334 | } | |
| 335 | 335 | ||
| 336 | 336 | 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, | ||
| 346 | 343 | done); | |
| 347 | 344 | }, | |
| 348 | 345 | ||
@@ -371,13 +368,8 @@ function newStreamWritableFromWritableStream(writableStream, options = kEmptyObj | |||
| 371 | 368 | } | |
| 372 | 369 | ||
| 373 | 370 | 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, | ||
| 381 | 373 | done); | |
| 382 | 374 | }, | |
| 383 | 375 | ||
@@ -789,15 +781,12 @@ function newStreamDuplexFromReadableWritablePair(pair = kEmptyObject, options = | |||
| 789 | 781 | } | |
| 790 | 782 | ||
| 791 | 783 | 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, | ||
| 801 | 790 | done); | |
| 802 | 791 | }, | |
| 803 | 792 | ||
@@ -826,13 +815,8 @@ function newStreamDuplexFromReadableWritablePair(pair = kEmptyObject, options = | |||
| 826 | 815 | } | |
| 827 | 816 | ||
| 828 | 817 | 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, | ||
| 836 | 820 | done); | |
| 837 | 821 | }, | |
| 838 | 822 | ||
0 commit comments