diff options
Diffstat (limited to 'src/js/builtins/ProcessObjectInternals.ts')
-rw-r--r-- | src/js/builtins/ProcessObjectInternals.ts | 19 |
1 files changed, 16 insertions, 3 deletions
diff --git a/src/js/builtins/ProcessObjectInternals.ts b/src/js/builtins/ProcessObjectInternals.ts index aa7c9b783..a72a96c2a 100644 --- a/src/js/builtins/ProcessObjectInternals.ts +++ b/src/js/builtins/ProcessObjectInternals.ts @@ -106,7 +106,7 @@ export function getStdinStream(fd) { if (event === "readable") { ref(); } - return originalOn.call(this, event, listener); + return originalOn.$call(this, event, listener); }; stream.fd = fd; @@ -114,13 +114,13 @@ export function getStdinStream(fd) { const originalPause = stream.pause; stream.pause = function () { unref(); - return originalPause.call(this); + return originalPause.$call(this); }; const originalResume = stream.resume; stream.resume = function () { ref(); - return originalResume.call(this); + return originalResume.$call(this); }; async function internalRead(stream) { @@ -252,6 +252,11 @@ export function initializeNextTickQueue(process, nextTickQueue, drainMicrotasksF // but allows much quicker checks. class FixedCircularBuffer { + top: number; + bottom: number; + list: Array<FixedCircularBuffer | undefined>; + next: FixedCircularBuffer | null; + constructor() { this.bottom = 0; this.top = 0; @@ -283,6 +288,9 @@ export function initializeNextTickQueue(process, nextTickQueue, drainMicrotasksF } class FixedQueue { + head: FixedCircularBuffer; + tail: FixedCircularBuffer; + constructor() { this.head = this.tail = new FixedCircularBuffer(); } @@ -381,3 +389,8 @@ export function initializeNextTickQueue(process, nextTickQueue, drainMicrotasksF return nextTick; } + +$getter; +export function mainModule() { + return $requireMap.$get(Bun.main); +} |