aboutsummaryrefslogtreecommitdiff
path: root/src/js/node/stream.js
diff options
context:
space:
mode:
Diffstat (limited to 'src/js/node/stream.js')
-rw-r--r--src/js/node/stream.js13
1 files changed, 4 insertions, 9 deletions
diff --git a/src/js/node/stream.js b/src/js/node/stream.js
index 30c76d797..474ada8d8 100644
--- a/src/js/node/stream.js
+++ b/src/js/node/stream.js
@@ -34,7 +34,7 @@ var debug = __DEBUG__
: (...args) => console.log(...args.slice(0, -1))
: () => {};
-var { isPromise, isCallable, direct, Object } = globalThis[Symbol.for("Bun.lazy")]("primordials");
+var { isPromise, isCallable, direct, Object } = $lazy("primordials");
import { EventEmitter as EE } from "bun:events_native";
import { StringDecoder } from "node:string_decoder";
@@ -2309,7 +2309,7 @@ var require_readable = __commonJS({
Symbol: Symbol2,
} = require_primordials();
- var ReadableState = globalThis[Symbol.for("Bun.lazy")]("bun:stream").ReadableState;
+ var ReadableState = $lazy("bun:stream").ReadableState;
var { Stream, prependListener } = require_legacy();
function Readable(options) {
@@ -2559,12 +2559,7 @@ var require_readable = __commonJS({
var { addAbortSignal } = require_add_abort_signal();
var eos = require_end_of_stream();
- const {
- maybeReadMore: _maybeReadMore,
- resume,
- emitReadable: _emitReadable,
- onEofChunk,
- } = globalThis[Symbol.for("Bun.lazy")]("bun:stream");
+ const { maybeReadMore: _maybeReadMore, resume, emitReadable: _emitReadable, onEofChunk } = $lazy("bun:stream");
function maybeReadMore(stream, state) {
process.nextTick(_maybeReadMore, stream, state);
}
@@ -5215,7 +5210,7 @@ var require_ours = __commonJS({
*
*/
function createNativeStreamReadable(nativeType, Readable) {
- var [pull, start, cancel, setClose, deinit, updateRef, drainFn] = globalThis[Symbol.for("Bun.lazy")](nativeType);
+ var [pull, start, cancel, setClose, deinit, updateRef, drainFn] = $lazy(nativeType);
var closer = [false];
var handleNumberResult = function (nativeReadable, result, view, isClosed) {