diff options
Diffstat (limited to 'src/js/node/stream.js')
-rw-r--r-- | src/js/node/stream.js | 13 |
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) { |