aboutsummaryrefslogtreecommitdiff
path: root/src/js/builtins/ReadableStreamInternals.ts
diff options
context:
space:
mode:
authorGravatar dave caruso <me@paperdave.net> 2023-09-14 00:39:36 -0400
committerGravatar GitHub <noreply@github.com> 2023-09-13 21:39:36 -0700
commit9976e3f528bae74667a2f4742c4b165b7f68c76d (patch)
treeeb4a123f5c533f73559f894bff77d5db65906a56 /src/js/builtins/ReadableStreamInternals.ts
parentfbafbd3394a2c1a1112df148fa2b151ee0955cc5 (diff)
downloadbun-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.ts10
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 } : {});