diff options
Diffstat (limited to 'chromium/third_party/blink/renderer/core/streams/TransformStream.js')
-rw-r--r-- | chromium/third_party/blink/renderer/core/streams/TransformStream.js | 21 |
1 files changed, 11 insertions, 10 deletions
diff --git a/chromium/third_party/blink/renderer/core/streams/TransformStream.js b/chromium/third_party/blink/renderer/core/streams/TransformStream.js index cafce4170f1..a339a49bb5d 100644 --- a/chromium/third_party/blink/renderer/core/streams/TransformStream.js +++ b/chromium/third_party/blink/renderer/core/streams/TransformStream.js @@ -42,11 +42,12 @@ const Promise = global.Promise; const thenPromise = v8.uncurryThis(Promise.prototype.then); - const Promise_resolve = Promise.resolve.bind(Promise); - const Promise_reject = Promise.reject.bind(Promise); // From CommonOperations.js const { + createPromise, + createRejectedPromise, + createResolvedPromise, hasOwnPropertyNoThrow, resolvePromise, CreateAlgorithmFromUnderlyingMethod, @@ -103,7 +104,7 @@ readableHighWaterMark = ValidateAndNormalizeHighWaterMark(readableHighWaterMark); - const startPromise = v8.createPromise(); + const startPromise = createPromise(); InitializeTransformStream( this, startPromise, writableHighWaterMark, writableSizeAlgorithm, readableHighWaterMark, readableSizeAlgorithm); @@ -159,7 +160,7 @@ // readableHighWaterMark >= 0, // '! IsNonNegativeNumber(_readableHighWaterMark_) is true'); const stream = ObjectCreate(TransformStream_prototype); - const startPromise = v8.createPromise(); + const startPromise = createPromise(); InitializeTransformStream( stream, startPromise, writableHighWaterMark, writableSizeAlgorithm, readableHighWaterMark, readableSizeAlgorithm); @@ -188,7 +189,7 @@ TransformStreamDefaultSourcePullAlgorithm(stream); const cancelAlgorithm = reason => { TransformStreamErrorWritableAndUnblockWrite(stream, reason); - return Promise_resolve(undefined); + return createResolvedPromise(undefined); }; stream[_readable] = binding.CreateReadableStream( startAlgorithm, pullAlgorithm, cancelAlgorithm, readableHighWaterMark, @@ -234,7 +235,7 @@ resolvePromise(stream[_backpressureChangePromise], undefined); } - stream[_backpressureChangePromise] = v8.createPromise(); + stream[_backpressureChangePromise] = createPromise(); stream[_backpressure] = backpressure; } @@ -316,9 +317,9 @@ transformAlgorithm = chunk => { try { TransformStreamDefaultControllerEnqueue(controller, chunk); - return Promise_resolve(); + return createResolvedPromise(); } catch (resultValue) { - return Promise_reject(resultValue); + return createRejectedPromise(resultValue); } }; } @@ -415,7 +416,7 @@ function TransformStreamDefaultSinkAbortAlgorithm(stream, reason) { TransformStreamError(stream, reason); - return Promise_resolve(); + return createResolvedPromise(); } function TransformStreamDefaultSinkCloseAlgorithm(stream) { @@ -458,7 +459,7 @@ // blink::TransformStream needs. |transformAlgorithm| and |flushAlgorithm| are // passed the controller, unlike in the standard. function createTransformStreamSimple(transformAlgorithm, flushAlgorithm) { - return CreateTransformStream(() => Promise_resolve(), + return CreateTransformStream(() => createResolvedPromise(), transformAlgorithm, flushAlgorithm); } function createTransformStream( |