direct streams mostly workjarred/direct

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";