diff options
Diffstat (limited to 'src/javascript/jsc/bindings/builtins/js/ReadableByteStreamInternals.js')
-rw-r--r-- | src/javascript/jsc/bindings/builtins/js/ReadableByteStreamInternals.js | 11 |
1 files changed, 10 insertions, 1 deletions
diff --git a/src/javascript/jsc/bindings/builtins/js/ReadableByteStreamInternals.js b/src/javascript/jsc/bindings/builtins/js/ReadableByteStreamInternals.js index 372c980a1..f59a7bdbc 100644 --- a/src/javascript/jsc/bindings/builtins/js/ReadableByteStreamInternals.js +++ b/src/javascript/jsc/bindings/builtins/js/ReadableByteStreamInternals.js @@ -61,12 +61,20 @@ function privateInitializeReadableByteStreamController(stream, underlyingByteSou @putByIdDirectPrivate(this, "cancel", @readableByteStreamControllerCancel); @putByIdDirectPrivate(this, "pull", @readableByteStreamControllerPull); + if (@getByIdDirectPrivate(underlyingByteSource, "lazy") === true) { + @putByIdDirectPrivate(this, "start", () => @readableStreamByteStreamControllerStart(this)); + } else { + @putByIdDirectPrivate(this, "start", @undefined); + @readableStreamByteStreamControllerStart(this); + } + return this; } function readableStreamByteStreamControllerStart(controller) { "use strict"; - + @putByIdDirectPrivate(controller, "start", @undefined); + if (@getByIdDirectPrivate(controller, "started") !== -1) return; @@ -84,6 +92,7 @@ function readableStreamByteStreamControllerStart(controller) { }); } + function privateInitializeReadableStreamBYOBRequest(controller, view) { "use strict"; |