diff options
author | 2022-12-18 08:52:50 -0800 | |
---|---|---|
committer | 2022-12-18 08:52:50 -0800 | |
commit | 79abd245e2219b4a694282e4cc80f66435aca9f8 (patch) | |
tree | 56196f9a3ca66c0fe55d45de163f1f8bc7416940 /src/bun.js/builtins/cpp/ProcessObjectInternalsBuiltins.cpp | |
parent | 2b622162ef6fc999ece19a9bbbc265af326b84a7 (diff) | |
download | bun-79abd245e2219b4a694282e4cc80f66435aca9f8.tar.gz bun-79abd245e2219b4a694282e4cc80f66435aca9f8.tar.zst bun-79abd245e2219b4a694282e4cc80f66435aca9f8.zip |
Regenerate builtins
Diffstat (limited to 'src/bun.js/builtins/cpp/ProcessObjectInternalsBuiltins.cpp')
-rw-r--r-- | src/bun.js/builtins/cpp/ProcessObjectInternalsBuiltins.cpp | 31 |
1 files changed, 27 insertions, 4 deletions
diff --git a/src/bun.js/builtins/cpp/ProcessObjectInternalsBuiltins.cpp b/src/bun.js/builtins/cpp/ProcessObjectInternalsBuiltins.cpp index 28cd73663..622374a50 100644 --- a/src/bun.js/builtins/cpp/ProcessObjectInternalsBuiltins.cpp +++ b/src/bun.js/builtins/cpp/ProcessObjectInternalsBuiltins.cpp @@ -472,10 +472,10 @@ const char* const s_processObjectInternalsGetStdioWriteStreamCode = const JSC::ConstructAbility s_processObjectInternalsGetStdinStreamCodeConstructAbility = JSC::ConstructAbility::CannotConstruct; const JSC::ConstructorKind s_processObjectInternalsGetStdinStreamCodeConstructorKind = JSC::ConstructorKind::None; const JSC::ImplementationVisibility s_processObjectInternalsGetStdinStreamCodeImplementationVisibility = JSC::ImplementationVisibility::Public; -const int s_processObjectInternalsGetStdinStreamCodeLength = 4019; +const int s_processObjectInternalsGetStdinStreamCodeLength = 4391; static const JSC::Intrinsic s_processObjectInternalsGetStdinStreamCodeIntrinsic = JSC::NoIntrinsic; const char* const s_processObjectInternalsGetStdinStreamCode = - "(function (fd, rawRequire, Bun) {\n" \ + "(function (fd_, rawRequire, Bun) {\n" \ " var module = { path: \"node:process\", require: rawRequire };\n" \ " var require = (path) => module.require(path);\n" \ "\n" \ @@ -489,6 +489,7 @@ const char* const s_processObjectInternalsGetStdinStreamCode = " #writeStream;\n" \ "\n" \ " #readable = true;\n" \ + " #unrefOnRead = false;\n" \ " #writable = true;\n" \ "\n" \ " #onFinish;\n" \ @@ -496,7 +497,7 @@ const char* const s_processObjectInternalsGetStdinStreamCode = " #onDrain;\n" \ "\n" \ " get isTTY() {\n" \ - " return require(\"tty\").isatty(fd);\n" \ + " return require(\"tty\").isatty(fd_);\n" \ " }\n" \ "\n" \ " get fd() {\n" \ @@ -551,20 +552,38 @@ const char* const s_processObjectInternalsGetStdinStreamCode = " }\n" \ " }\n" \ "\n" \ + " on(name, callback) {\n" \ + " //\n" \ + " //\n" \ + " //\n" \ + " //\n" \ + " //\n" \ + " //\n" \ + " //\n" \ + " //\n" \ + " //\n" \ + " if (name === \"readable\") {\n" \ + " this.ref();\n" \ + " this.#unrefOnRead = true;\n" \ + " }\n" \ + " return super.on(name, callback);\n" \ + " }\n" \ + "\n" \ " pause() {\n" \ " this.unref();\n" \ " return super.pause();\n" \ " }\n" \ "\n" \ " resume() {\n" \ - " this.#reader ??= Bun.stdin.stream().getReader();\n" \ " this.ref();\n" \ " return super.resume();\n" \ " }\n" \ "\n" \ " ref() {\n" \ + " this.#reader ??= Bun.stdin.stream().getReader();\n" \ " this.#readRef ??= setInterval(() => {}, 1 << 30);\n" \ " }\n" \ + "\n" \ " unref() {\n" \ " if (this.#readRef) {\n" \ " clearInterval(this.#readRef);\n" \ @@ -605,6 +624,10 @@ const char* const s_processObjectInternalsGetStdinStreamCode = " }\n" \ "\n" \ " _read(size) {\n" \ + " if (this.#unrefOnRead) {\n" \ + " this.unref();\n" \ + " this.#unrefOnRead = false;\n" \ + " }\n" \ " this.#readInternal();\n" \ " }\n" \ "\n" \ |