1 files changed, 7 insertions, 6 deletions
diff --git a/src/js/builtins/ReadableStreamInternals.ts b/src/js/builtins/ReadableStreamInternals.ts
index e249aea0a..36f049f3e 100644
--- a/src/js/builtins/ReadableStreamInternals.ts
+++ b/src/js/builtins/ReadableStreamInternals.ts
@@ -1034,7 +1034,8 @@ export function createTextStream(highWaterMark) {
       if (byteLength > 0) {
         hasBuffer = true;
         if (rope.length > 0) {
-          $arrayPush(array, rope, chunk);
+          $arrayPush(array, rope);
+          $arrayPush(array, chunk);
           rope = "";
         } else {
           $arrayPush(array, chunk);
@@ -1073,12 +1074,12 @@ export function createTextStream(highWaterMark) {
       }
 
       if (hasBuffer && !hasString) {
-        return new globalThis.TextDecoder().decode($Bun.concatArrayBuffers(array));
+        return new globalThis.TextDecoder().decode(Bun.concatArrayBuffers(array));
       }
 
       // worst case: mixed content
 
-      var arrayBufferSink = new $Bun.ArrayBufferSink();
+      var arrayBufferSink = new Bun.ArrayBufferSink();
       arrayBufferSink.start({
         highWaterMark: estimatedLength,
         asUint8Array: true,
@@ -1205,7 +1206,7 @@ export function initializeArrayBufferStream(underlyingSource, highWaterMark) {
     highWaterMark && typeof highWaterMark === "number"
       ? { highWaterMark, stream: true, asUint8Array: true }
       : { stream: true, asUint8Array: true };
-  var sink = new $Bun.ArrayBufferSink();
+  var sink = new Bun.ArrayBufferSink();
   sink.start(opts);
 
   var controller = {
@@ -1492,7 +1493,7 @@ export function lazyLoadStream(stream, autoAllocateChunkSize) {
   var nativePtr = $getByIdDirectPrivate(stream, "bunNativePtr");
   var Prototype = $lazyStreamPrototypeMap.$get(nativeType);
   if (Prototype === undefined) {
-    var [pull, start, cancel, setClose, deinit, setRefOrUnref, drain] = $lazyLoad(nativeType);
+    var [pull, start, cancel, setClose, deinit, setRefOrUnref, drain] = $lazy(nativeType);
     var closer = [false];
     var handleResult;
     function handleNativeReadableStreamPromiseResult(val) {
@@ -1679,7 +1680,7 @@ export function readableStreamIntoText(stream) {
 }
 
 export function readableStreamToArrayBufferDirect(stream, underlyingSource) {
-  var sink = new $Bun.ArrayBufferSink();
+  var sink = new Bun.ArrayBufferSink();
   $putByIdDirectPrivate(stream, "underlyingSource", undefined);
   var highWaterMark = $getByIdDirectPrivate(stream, "highWaterMark");
   sink.start(highWaterMark ? { highWaterMark } : {});