aboutsummaryrefslogtreecommitdiff
path: root/src/bun.js/builtins/js
diff options
context:
space:
mode:
Diffstat (limited to 'src/bun.js/builtins/js')
-rw-r--r--src/bun.js/builtins/js/ReadableStream.js2
-rw-r--r--src/bun.js/builtins/js/ReadableStreamInternals.js4
2 files changed, 6 insertions, 0 deletions
diff --git a/src/bun.js/builtins/js/ReadableStream.js b/src/bun.js/builtins/js/ReadableStream.js
index 8496b2d4b..42c0fbdbc 100644
--- a/src/bun.js/builtins/js/ReadableStream.js
+++ b/src/bun.js/builtins/js/ReadableStream.js
@@ -244,6 +244,8 @@ function consumeReadableStream(nativePtr, nativeType, inputStream) {
} else {
return -1;
}
+
+
}
readMany() {
diff --git a/src/bun.js/builtins/js/ReadableStreamInternals.js b/src/bun.js/builtins/js/ReadableStreamInternals.js
index 7be9410db..a1e496290 100644
--- a/src/bun.js/builtins/js/ReadableStreamInternals.js
+++ b/src/bun.js/builtins/js/ReadableStreamInternals.js
@@ -1855,6 +1855,8 @@ function lazyLoadStream(stream, autoAllocateChunkSize) {
handleResult = function handleResult(result, controller, view) {
"use strict";
+ console.log("handleResult", result, controller, view);
+
if (result && @isPromise(result)) {
return result.then(
handleNativeReadableStreamPromiseResult.bind({
@@ -1865,8 +1867,10 @@ function lazyLoadStream(stream, autoAllocateChunkSize) {
);
} else if (result !== false) {
if (view && view.byteLength === result) {
+ console.log("view", result, controller.byobRequest);
controller.byobRequest.respondWithNewView(view);
} else {
+ console.log("result", result, controller.byobRequest);
controller.byobRequest.respond(result);
}
}