aboutsummaryrefslogtreecommitdiff
path: root/src/bun.js/builtins/js
diff options
context:
space:
mode:
Diffstat (limited to 'src/bun.js/builtins/js')
-rw-r--r--src/bun.js/builtins/js/ReadableStream.js6
-rw-r--r--src/bun.js/builtins/js/ReadableStreamInternals.js8
2 files changed, 7 insertions, 7 deletions
diff --git a/src/bun.js/builtins/js/ReadableStream.js b/src/bun.js/builtins/js/ReadableStream.js
index fbd8148ba..a8aa5d8f3 100644
--- a/src/bun.js/builtins/js/ReadableStream.js
+++ b/src/bun.js/builtins/js/ReadableStream.js
@@ -135,20 +135,20 @@ function readableStreamToArrayBuffer(stream) {
return @readableStreamToArrayBufferDirect(stream, underlyingSource);
}
- return globalThis.Bun.readableStreamToArray(stream).@then(globalThis.Bun.concatArrayBuffers);
+ return @Bun.readableStreamToArray(stream).@then(@Bun.concatArrayBuffers);
}
@globalPrivate
function readableStreamToJSON(stream) {
"use strict";
- return globalThis.Bun.readableStreamToText(stream).@then(globalThis.JSON.parse);
+ return @Bun.readableStreamToText(stream).@then(globalThis.JSON.parse);
}
@globalPrivate
function readableStreamToBlob(stream) {
"use strict";
- return @Promise.resolve(globalThis.Bun.readableStreamToArray(stream)).@then(array => new Blob(array));
+ return @Promise.resolve(@Bun.readableStreamToArray(stream)).@then(array => new Blob(array));
}
@globalPrivate
diff --git a/src/bun.js/builtins/js/ReadableStreamInternals.js b/src/bun.js/builtins/js/ReadableStreamInternals.js
index 0f5871fa1..3a02669dc 100644
--- a/src/bun.js/builtins/js/ReadableStreamInternals.js
+++ b/src/bun.js/builtins/js/ReadableStreamInternals.js
@@ -1302,13 +1302,13 @@ function createTextStream(highWaterMark) {
if (hasBuffer && !hasString) {
return new globalThis.TextDecoder().decode(
- globalThis.Bun.concatArrayBuffers(array)
+ @Bun.concatArrayBuffers(array)
);
}
// worst case: mixed content
- var arrayBufferSink = new globalThis.Bun.ArrayBufferSink();
+ var arrayBufferSink = new @Bun.ArrayBufferSink();
arrayBufferSink.start({
highWaterMark: estimatedLength,
asUint8Array: true,
@@ -1440,7 +1440,7 @@ function initializeArrayBufferStream(underlyingSource, highWaterMark) {
highWaterMark && typeof highWaterMark === "number"
? { highWaterMark, stream: true, asUint8Array: true }
: { stream: true, asUint8Array: true };
- var sink = new globalThis.Bun.ArrayBufferSink();
+ var sink = new @Bun.ArrayBufferSink();
sink.start(opts);
var controller = {
@@ -1972,7 +1972,7 @@ function readableStreamIntoText(stream) {
function readableStreamToArrayBufferDirect(stream, underlyingSource) {
"use strict";
- var sink = new globalThis.Bun.ArrayBufferSink();
+ var sink = new @Bun.ArrayBufferSink();
@putByIdDirectPrivate(stream, "underlyingSource", @undefined);
var highWaterMark = @getByIdDirectPrivate(stream, "highWaterMark");
sink.start(highWaterMark ? { highWaterMark } : {});