summaryrefslogtreecommitdiffstats
path: root/chromium/third_party/blink/renderer/core/streams/TransformStream.js
diff options
context:
space:
mode:
Diffstat (limited to 'chromium/third_party/blink/renderer/core/streams/TransformStream.js')
-rw-r--r--chromium/third_party/blink/renderer/core/streams/TransformStream.js21
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(