diff options
| author |  Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com>
| 2022-11-25 00:05:33 -0800 |
|---|---|---|
| committer | Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com>
| 2022-11-25 00:05:33 -0800 |
| commit | 0b915fed034c38ae9a2e15caee94530910dc864b (patch) | |
| tree | 3d69a11fd2a424b368a12b985fccf6c1b75ab3d0 /src/bun.js/builtins/js/ReadableStreamInternals.js | |
| parent | 7b23cb5cd7413564dae58a44e511d0640fb339d4 (diff) | |
| download | bun-0b915fed034c38ae9a2e15caee94530910dc864b.tar.gz bun-0b915fed034c38ae9a2e15caee94530910dc864b.tar.zst bun-0b915fed034c38ae9a2e15caee94530910dc864b.zip | |
[streams] Always call start
Diffstat (limited to 'src/bun.js/builtins/js/ReadableStreamInternals.js')
| -rw-r--r-- | src/bun.js/builtins/js/ReadableStreamInternals.js | 10 |
1 files changed, 4 insertions, 6 deletions
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 ( |