diff options
Diffstat (limited to 'src/bun.js/builtins')
4 files changed, 14 insertions, 2 deletions
diff --git a/src/bun.js/builtins/cpp/ReadableStreamBuiltins.cpp b/src/bun.js/builtins/cpp/ReadableStreamBuiltins.cpp index 2b0797381..830fbfd51 100644 --- a/src/bun.js/builtins/cpp/ReadableStreamBuiltins.cpp +++ b/src/bun.js/builtins/cpp/ReadableStreamBuiltins.cpp @@ -214,7 +214,7 @@ const char* const s_readableStreamReadableStreamToBlobCode = const JSC::ConstructAbility s_readableStreamConsumeReadableStreamCodeConstructAbility = JSC::ConstructAbility::CannotConstruct; const JSC::ConstructorKind s_readableStreamConsumeReadableStreamCodeConstructorKind = JSC::ConstructorKind::None; const JSC::ImplementationVisibility s_readableStreamConsumeReadableStreamCodeImplementationVisibility = JSC::ImplementationVisibility::Private; -const int s_readableStreamConsumeReadableStreamCodeLength = 3718; +const int s_readableStreamConsumeReadableStreamCodeLength = 3736; static const JSC::Intrinsic s_readableStreamConsumeReadableStreamCodeIntrinsic = JSC::NoIntrinsic; const char* const s_readableStreamConsumeReadableStreamCode = "(function (nativePtr, nativeType, inputStream) {\n" \ @@ -309,6 +309,8 @@ const char* const s_readableStreamConsumeReadableStreamCode = " } else {\n" \ " return -1;\n" \ " }\n" \ + "\n" \ + " \n" \ " }\n" \ "\n" \ " readMany() {\n" \ diff --git a/src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp b/src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp index e39802ee5..a862fc0b4 100644 --- a/src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp +++ b/src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp @@ -2253,7 +2253,7 @@ const char* const s_readableStreamInternalsReadableStreamDefaultControllerCanClo const JSC::ConstructAbility s_readableStreamInternalsLazyLoadStreamCodeConstructAbility = JSC::ConstructAbility::CannotConstruct; const JSC::ConstructorKind s_readableStreamInternalsLazyLoadStreamCodeConstructorKind = JSC::ConstructorKind::None; const JSC::ImplementationVisibility s_readableStreamInternalsLazyLoadStreamCodeImplementationVisibility = JSC::ImplementationVisibility::Public; -const int s_readableStreamInternalsLazyLoadStreamCodeLength = 2505; +const int s_readableStreamInternalsLazyLoadStreamCodeLength = 2701; static const JSC::Intrinsic s_readableStreamInternalsLazyLoadStreamCodeIntrinsic = JSC::NoIntrinsic; const char* const s_readableStreamInternalsLazyLoadStreamCode = "(function (stream, autoAllocateChunkSize) {\n" \ @@ -2277,6 +2277,8 @@ const char* const s_readableStreamInternalsLazyLoadStreamCode = " handleResult = function handleResult(result, controller, view) {\n" \ " \"use strict\";\n" \ "\n" \ + " console.log(\"handleResult\", result, controller, view);\n" \ + " \n" \ " if (result && @isPromise(result)) {\n" \ " return result.then(\n" \ " handleNativeReadableStreamPromiseResult.bind({\n" \ @@ -2287,8 +2289,10 @@ const char* const s_readableStreamInternalsLazyLoadStreamCode = " );\n" \ " } else if (result !== false) {\n" \ " if (view && view.byteLength === result) {\n" \ + " console.log(\"view\", result, controller.byobRequest);\n" \ " controller.byobRequest.respondWithNewView(view);\n" \ " } else {\n" \ + " console.log(\"result\", result, controller.byobRequest);\n" \ " controller.byobRequest.respond(result);\n" \ " }\n" \ " }\n" \ 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); } } |