diff options
Diffstat (limited to '')
| -rw-r--r-- | src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp | 14 | ||||
| -rw-r--r-- | src/bun.js/builtins/js/ReadableStreamInternals.js | 10 |
2 files changed, 10 insertions, 14 deletions
diff --git a/src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp b/src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp index 335ab6ccb..1e9e81519 100644 --- a/src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp +++ b/src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp @@ -986,7 +986,7 @@ const char* const s_readableStreamInternalsIsReadableStreamDefaultControllerCode const JSC::ConstructAbility s_readableStreamInternalsReadDirectStreamCodeConstructAbility = JSC::ConstructAbility::CannotConstruct; const JSC::ConstructorKind s_readableStreamInternalsReadDirectStreamCodeConstructorKind = JSC::ConstructorKind::None; const JSC::ImplementationVisibility s_readableStreamInternalsReadDirectStreamCodeImplementationVisibility = JSC::ImplementationVisibility::Public; -const int s_readableStreamInternalsReadDirectStreamCodeLength = 1598; +const int s_readableStreamInternalsReadDirectStreamCodeLength = 1583; static const JSC::Intrinsic s_readableStreamInternalsReadDirectStreamCodeIntrinsic = JSC::NoIntrinsic; const char* const s_readableStreamInternalsReadDirectStreamCode = "(function (stream, sink, underlyingSource) {\n" \ @@ -1037,11 +1037,9 @@ const char* const s_readableStreamInternalsReadDirectStreamCode = " @putByIdDirectPrivate(stream, \"readableStreamController\", sink);\n" \ " const highWaterMark = @getByIdDirectPrivate(stream, \"highWaterMark\");\n" \ "\n" \ - " if (highWaterMark) {\n" \ - " sink.start({\n" \ - " highWaterMark: highWaterMark < 64 ? 64 : highWaterMark,\n" \ - " });\n" \ - " }\n" \ + " sink.start({\n" \ + " highWaterMark: !highWaterMark || highWaterMark < 64 ? 64 : highWaterMark,\n" \ + " });\n" \ "\n" \ " @startDirectStream.@call(sink, stream, underlyingSource.pull, close);\n" \ " @putByIdDirectPrivate(stream, \"reader\", {});\n" \ @@ -1090,7 +1088,7 @@ const char* const s_readableStreamInternalsAssignToStreamCode = const JSC::ConstructAbility s_readableStreamInternalsReadStreamIntoSinkCodeConstructAbility = JSC::ConstructAbility::CannotConstruct; const JSC::ConstructorKind s_readableStreamInternalsReadStreamIntoSinkCodeConstructorKind = JSC::ConstructorKind::None; const JSC::ImplementationVisibility s_readableStreamInternalsReadStreamIntoSinkCodeImplementationVisibility = JSC::ImplementationVisibility::Public; -const int s_readableStreamInternalsReadStreamIntoSinkCodeLength = 2868; +const int s_readableStreamInternalsReadStreamIntoSinkCodeLength = 2869; static const JSC::Intrinsic s_readableStreamInternalsReadStreamIntoSinkCodeIntrinsic = JSC::NoIntrinsic; const char* const s_readableStreamInternalsReadStreamIntoSinkCode = "(async function (stream, sink, isNative) {\n" \ @@ -1112,7 +1110,7 @@ const char* const s_readableStreamInternalsReadStreamIntoSinkCode = " const highWaterMark = @getByIdDirectPrivate(stream, \"highWaterMark\");\n" \ " if (isNative) @startDirectStream.@call(sink, stream, @undefined, () => !didThrow && @markPromiseAsHandled(stream.cancel()));\n" \ "\n" \ - " if (highWaterMark) sink.start({ highWaterMark });\n" \ + " sink.start({ highWaterMark: highWaterMark || 0 });\n" \ " \n" \ "\n" \ " for (\n" \ diff --git a/src/bun.js/builtins/js/ReadableStreamInternals.js b/src/bun.js/builtins/js/ReadableStreamInternals.js index dfb9561ce..3e715a542 100644 --- a/src/bun.js/builtins/js/ReadableStreamInternals.js +++ b/src/bun.js/builtins/js/ReadableStreamInternals.js @@ -837,11 +837,9 @@ function readDirectStream(stream, sink, underlyingSource) { @putByIdDirectPrivate(stream, "readableStreamController", sink); const highWaterMark = @getByIdDirectPrivate(stream, "highWaterMark"); - if (highWaterMark) { - sink.start({ - highWaterMark: highWaterMark < 64 ? 64 : highWaterMark, - }); - } + sink.start({ + highWaterMark: !highWaterMark || highWaterMark < 64 ? 64 : highWaterMark, + }); @startDirectStream.@call(sink, stream, underlyingSource.pull, close); @putByIdDirectPrivate(stream, "reader", {}); @@ -899,7 +897,7 @@ async function readStreamIntoSink(stream, sink, isNative) { const highWaterMark = @getByIdDirectPrivate(stream, "highWaterMark"); if (isNative) @startDirectStream.@call(sink, stream, @undefined, () => !didThrow && @markPromiseAsHandled(stream.cancel())); - if (highWaterMark) sink.start({ highWaterMark }); + sink.start({ highWaterMark: highWaterMark || 0 }); for ( |