|
1 | 1 | 'use strict';
|
2 | 2 |
|
3 | 3 | const {
|
4 |
| - ArrayPrototypeMap, |
5 |
| - PromiseAll, |
6 | 4 | PromisePrototypeThen,
|
7 |
| - PromisePrototypeFinally, |
8 | 5 | PromiseResolve,
|
| 6 | + SafePromiseAll, |
| 7 | + SafePromisePrototypeFinally, |
9 | 8 | Uint8Array,
|
10 | 9 | } = primordials;
|
11 | 10 |
|
@@ -165,7 +164,7 @@ function newWritableStreamFromStreamWritable(streamWritable) {
|
165 | 164 | async write(chunk) {
|
166 | 165 | if (streamWritable.writableNeedDrain || !streamWritable.write(chunk)) {
|
167 | 166 | backpressurePromise = createDeferredPromise();
|
168 |
| - return PromisePrototypeFinally( |
| 167 | + return SafePromisePrototypeFinally( |
169 | 168 | backpressurePromise.promise, () => {
|
170 | 169 | backpressurePromise = undefined;
|
171 | 170 | });
|
@@ -246,10 +245,9 @@ function newStreamWritableFromWritableStream(writableStream, options = kEmptyObj
|
246 | 245 | writer.ready,
|
247 | 246 | () => {
|
248 | 247 | return PromisePrototypeThen(
|
249 |
| - PromiseAll( |
250 |
| - ArrayPrototypeMap( |
251 |
| - chunks, |
252 |
| - (data) => writer.write(data.chunk))), |
| 248 | + SafePromiseAll( |
| 249 | + chunks, |
| 250 | + (data) => writer.write(data.chunk)), |
253 | 251 | done,
|
254 | 252 | done);
|
255 | 253 | },
|
@@ -668,10 +666,9 @@ function newStreamDuplexFromReadableWritablePair(pair = kEmptyObject, options =
|
668 | 666 | writer.ready,
|
669 | 667 | () => {
|
670 | 668 | return PromisePrototypeThen(
|
671 |
| - PromiseAll( |
672 |
| - ArrayPrototypeMap( |
673 |
| - chunks, |
674 |
| - (data) => writer.write(data.chunk))), |
| 669 | + SafePromiseAll( |
| 670 | + chunks, |
| 671 | + (data) => writer.write(data.chunk)), |
675 | 672 | done,
|
676 | 673 | done);
|
677 | 674 | },
|
@@ -767,7 +764,7 @@ function newStreamDuplexFromReadableWritablePair(pair = kEmptyObject, options =
|
767 | 764 |
|
768 | 765 | if (!writableClosed || !readableClosed) {
|
769 | 766 | PromisePrototypeThen(
|
770 |
| - PromiseAll([ |
| 767 | + SafePromiseAll([ |
771 | 768 | closeWriter(),
|
772 | 769 | closeReader(),
|
773 | 770 | ]),
|
|
0 commit comments