aboutsummaryrefslogtreecommitdiff
path: root/src/js/builtins/ProcessObjectInternals.ts
diff options
context:
space:
mode:
Diffstat (limited to 'src/js/builtins/ProcessObjectInternals.ts')
-rw-r--r--src/js/builtins/ProcessObjectInternals.ts19
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);
+}