diff options
author | 2023-07-23 22:37:48 -0700 | |
---|---|---|
committer | 2023-07-23 22:37:48 -0700 | |
commit | 967ccb5d50b3ce163bb98fd125c56b039743de90 (patch) | |
tree | 39a5af943cdce0efc3cff951ec3ae769a2c8fbcc /src/js/builtins/TransformStreamInternals.ts | |
parent | d8135e85ca28272bd01c4ffef07441ff33baaf0a (diff) | |
download | bun-967ccb5d50b3ce163bb98fd125c56b039743de90.tar.gz bun-967ccb5d50b3ce163bb98fd125c56b039743de90.tar.zst bun-967ccb5d50b3ce163bb98fd125c56b039743de90.zip |
Upgrade WebKit (#3777)
* Upgrade to latest WebKit
* Upgrade WebKit
* hm
* Fix failing tests
* Delete utf8-encoding-fixture.bin.cmp
---------
Co-authored-by: Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com>
Diffstat (limited to 'src/js/builtins/TransformStreamInternals.ts')
-rw-r--r-- | src/js/builtins/TransformStreamInternals.ts | 30 |
1 files changed, 15 insertions, 15 deletions
diff --git a/src/js/builtins/TransformStreamInternals.ts b/src/js/builtins/TransformStreamInternals.ts index 9da403e71..103b0651f 100644 --- a/src/js/builtins/TransformStreamInternals.ts +++ b/src/js/builtins/TransformStreamInternals.ts @@ -57,7 +57,7 @@ export function createTransformStream( const startPromiseCapability = $newPromiseCapability(Promise); $initializeTransformStream( stream, - startPromiseCapability.$promise, + startPromiseCapability.promise, writableHighWaterMark, writableSizeAlgorithm, readableHighWaterMark, @@ -69,10 +69,10 @@ export function createTransformStream( startAlgorithm().$then( () => { - startPromiseCapability.$resolve.$call(); + startPromiseCapability.resolve.$call(); }, error => { - startPromiseCapability.$reject.$call(undefined, error); + startPromiseCapability.reject.$call(undefined, error); }, ); @@ -158,7 +158,7 @@ export function transformStreamSetBackpressure(stream, backpressure) { $assert($getByIdDirectPrivate(stream, "backpressure") !== backpressure); const backpressureChangePromise = $getByIdDirectPrivate(stream, "backpressureChangePromise"); - if (backpressureChangePromise !== undefined) backpressureChangePromise.$resolve.$call(); + if (backpressureChangePromise !== undefined) backpressureChangePromise.resolve.$call(); $putByIdDirectPrivate(stream, "backpressureChangePromise", $newPromiseCapability(Promise)); $putByIdDirectPrivate(stream, "backpressure", backpressure); @@ -245,10 +245,10 @@ export function transformStreamDefaultControllerPerformTransform(controller, chu }, r => { $transformStreamError($getByIdDirectPrivate(controller, "stream"), r); - promiseCapability.$reject.$call(undefined, r); + promiseCapability.reject.$call(undefined, r); }, ); - return promiseCapability.$promise; + return promiseCapability.promise; } export function transformStreamDefaultControllerTerminate(controller) { @@ -275,11 +275,11 @@ export function transformStreamDefaultSinkWriteAlgorithm(stream, chunk) { const backpressureChangePromise = $getByIdDirectPrivate(stream, "backpressureChangePromise"); $assert(backpressureChangePromise !== undefined); - backpressureChangePromise.$promise.$then( + backpressureChangePromise.promise.$then( () => { const state = $getByIdDirectPrivate(writable, "state"); if (state === "erroring") { - promiseCapability.$reject.$call(undefined, $getByIdDirectPrivate(writable, "storedError")); + promiseCapability.reject.$call(undefined, $getByIdDirectPrivate(writable, "storedError")); return; } @@ -289,16 +289,16 @@ export function transformStreamDefaultSinkWriteAlgorithm(stream, chunk) { promiseCapability.$resolve(); }, e => { - promiseCapability.$reject.$call(undefined, e); + promiseCapability.reject.$call(undefined, e); }, ); }, e => { - promiseCapability.$reject.$call(undefined, e); + promiseCapability.reject.$call(undefined, e); }, ); - return promiseCapability.$promise; + return promiseCapability.promise; } return $transformStreamDefaultControllerPerformTransform(controller, chunk); } @@ -322,7 +322,7 @@ export function transformStreamDefaultSinkCloseAlgorithm(stream) { flushPromise.$then( () => { if ($getByIdDirectPrivate(readable, "state") === $streamErrored) { - promiseCapability.$reject.$call(undefined, $getByIdDirectPrivate(readable, "storedError")); + promiseCapability.reject.$call(undefined, $getByIdDirectPrivate(readable, "storedError")); return; } @@ -333,10 +333,10 @@ export function transformStreamDefaultSinkCloseAlgorithm(stream) { }, r => { $transformStreamError($getByIdDirectPrivate(controller, "stream"), r); - promiseCapability.$reject.$call(undefined, $getByIdDirectPrivate(readable, "storedError")); + promiseCapability.reject.$call(undefined, $getByIdDirectPrivate(readable, "storedError")); }, ); - return promiseCapability.$promise; + return promiseCapability.promise; } export function transformStreamDefaultSourcePullAlgorithm(stream) { @@ -345,5 +345,5 @@ export function transformStreamDefaultSourcePullAlgorithm(stream) { $transformStreamSetBackpressure(stream, false); - return $getByIdDirectPrivate(stream, "backpressureChangePromise").$promise; + return $getByIdDirectPrivate(stream, "backpressureChangePromise").promise; } |