diff options
author | 2023-09-14 00:39:36 -0400 | |
---|---|---|
committer | 2023-09-13 21:39:36 -0700 | |
commit | 9976e3f528bae74667a2f4742c4b165b7f68c76d (patch) | |
tree | eb4a123f5c533f73559f894bff77d5db65906a56 /src/js/builtins/ReadableStreamInternals.ts | |
parent | fbafbd3394a2c1a1112df148fa2b151ee0955cc5 (diff) | |
download | bun-9976e3f528bae74667a2f4742c4b165b7f68c76d.tar.gz bun-9976e3f528bae74667a2f4742c4b165b7f68c76d.tar.zst bun-9976e3f528bae74667a2f4742c4b165b7f68c76d.zip |
fix(runtime): make most globals configurable/deletable, allow resuming the console iterator (#5216)
* Fix #5177
* Fix #5175
* make most globals deletable/overridable
* not done
* cool
* a
* done
* fix test
* oops
* yippee
Diffstat (limited to 'src/js/builtins/ReadableStreamInternals.ts')
-rw-r--r-- | src/js/builtins/ReadableStreamInternals.ts | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/js/builtins/ReadableStreamInternals.ts b/src/js/builtins/ReadableStreamInternals.ts index e249aea0a..ca263363c 100644 --- a/src/js/builtins/ReadableStreamInternals.ts +++ b/src/js/builtins/ReadableStreamInternals.ts @@ -1073,12 +1073,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 +1205,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 +1492,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 +1679,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 } : {}); |