diff options
author | 2022-08-09 01:34:17 -0700 | |
---|---|---|
committer | 2022-08-09 01:41:13 -0700 | |
commit | 4575df38e64b75e356821f9bfb948f54f147b96e (patch) | |
tree | e2a07803c00f4f6a006608d05a1207c5e2070d41 /src/bun.js/builtins/js | |
parent | b36b7fee16a5239cfb50cfde94ed871d60032b3c (diff) | |
download | bun-4575df38e64b75e356821f9bfb948f54f147b96e.tar.gz bun-4575df38e64b75e356821f9bfb948f54f147b96e.tar.zst bun-4575df38e64b75e356821f9bfb948f54f147b96e.zip |
[misc] Add a global private `@Bun`
Diffstat (limited to 'src/bun.js/builtins/js')
-rw-r--r-- | src/bun.js/builtins/js/ReadableStream.js | 6 | ||||
-rw-r--r-- | src/bun.js/builtins/js/ReadableStreamInternals.js | 8 |
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 } : {}); |