aboutsummaryrefslogtreecommitdiff
path: root/src/javascript/jsc/bindings/builtins/js/ReadableByteStreamInternals.js
diff options
context:
space:
mode:
Diffstat (limited to 'src/javascript/jsc/bindings/builtins/js/ReadableByteStreamInternals.js')
-rw-r--r--src/javascript/jsc/bindings/builtins/js/ReadableByteStreamInternals.js11
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";