diff options
Diffstat (limited to 'src/js/builtins')
| -rw-r--r-- | src/js/builtins/ReadableStreamDefaultReader.ts | 1 | ||||
| -rw-r--r-- | src/js/builtins/TransformStreamInternals.ts | 6 |
2 files changed, 3 insertions, 4 deletions
diff --git a/src/js/builtins/ReadableStreamDefaultReader.ts b/src/js/builtins/ReadableStreamDefaultReader.ts index b4e0c2bd3..ea1a64b68 100644 --- a/src/js/builtins/ReadableStreamDefaultReader.ts +++ b/src/js/builtins/ReadableStreamDefaultReader.ts @@ -59,7 +59,6 @@ export function readMany(this: ReadableStreamDefaultReader): ReadableStreamDefau var controller = $getByIdDirectPrivate(stream, "readableStreamController"); var queue = $getByIdDirectPrivate(controller, "queue"); - if (!queue) { // This is a ReadableStream direct controller implemented in JS // It hasn't been started yet. diff --git a/src/js/builtins/TransformStreamInternals.ts b/src/js/builtins/TransformStreamInternals.ts index 103b0651f..833fafdc6 100644 --- a/src/js/builtins/TransformStreamInternals.ts +++ b/src/js/builtins/TransformStreamInternals.ts @@ -241,7 +241,7 @@ export function transformStreamDefaultControllerPerformTransform(controller, chu const transformPromise = $getByIdDirectPrivate(controller, "transformAlgorithm").$call(undefined, chunk); transformPromise.$then( () => { - promiseCapability.$resolve(); + promiseCapability.resolve(); }, r => { $transformStreamError($getByIdDirectPrivate(controller, "stream"), r); @@ -286,7 +286,7 @@ export function transformStreamDefaultSinkWriteAlgorithm(stream, chunk) { $assert(state === "writable"); $transformStreamDefaultControllerPerformTransform(controller, chunk).$then( () => { - promiseCapability.$resolve(); + promiseCapability.resolve(); }, e => { promiseCapability.reject.$call(undefined, e); @@ -329,7 +329,7 @@ export function transformStreamDefaultSinkCloseAlgorithm(stream) { // FIXME: Update readableStreamDefaultControllerClose to make this check. if ($readableStreamDefaultControllerCanCloseOrEnqueue(readableController)) $readableStreamDefaultControllerClose(readableController); - promiseCapability.$resolve(); + promiseCapability.resolve(); }, r => { $transformStreamError($getByIdDirectPrivate(controller, "stream"), r); |