From 0b915fed034c38ae9a2e15caee94530910dc864b Mon Sep 17 00:00:00 2001
From: Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com>
Date: Fri, 25 Nov 2022 00:05:33 -0800
Subject: [streams] Always call start

---
 src/bun.js/builtins/js/ReadableStreamInternals.js | 10 ++++------
 1 file changed, 4 insertions(+), 6 deletions(-)

(limited to 'src/bun.js/builtins/js/ReadableStreamInternals.js')

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 (
-- 
cgit v1.2.3