summaryrefslogtreecommitdiff
path: root/cli/rt/99_main.js
diff options
context:
space:
mode:
authorBartek IwaƄczuk <biwanczuk@gmail.com>2020-09-16 22:22:43 +0200
committerGitHub <noreply@github.com>2020-09-16 22:22:43 +0200
commit6c4da0e429eb47dae6a220c5576a39f137615bb8 (patch)
treea8715428caea00105acc9a10fcd0f356085d3fa7 /cli/rt/99_main.js
parent104aebdfb5d01f7482bacef6d58c2ce16da44334 (diff)
refactor: remove dispatch_json.js from cli/rt and cli/tsc (#7521)
Instead use Deno.core.jsonOpSync and Deno.core.jsonOpAsync
Diffstat (limited to 'cli/rt/99_main.js')
-rw-r--r--cli/rt/99_main.js23
1 files changed, 7 insertions, 16 deletions
diff --git a/cli/rt/99_main.js b/cli/rt/99_main.js
index 74a7bd2a8..03bd77be4 100644
--- a/cli/rt/99_main.js
+++ b/cli/rt/99_main.js
@@ -7,7 +7,6 @@ delete Object.prototype.__proto__;
const core = Deno.core;
const util = window.__bootstrap.util;
const eventTarget = window.__bootstrap.eventTarget;
- const dispatchJson = window.__bootstrap.dispatchJson;
const dispatchMinimal = window.__bootstrap.dispatchMinimal;
const build = window.__bootstrap.build;
const version = window.__bootstrap.version;
@@ -129,29 +128,19 @@ delete Object.prototype.__proto__;
}
function opPostMessage(data) {
- dispatchJson.sendSync("op_worker_post_message", {}, data);
+ core.jsonOpSync("op_worker_post_message", {}, data);
}
function opCloseWorker() {
- dispatchJson.sendSync("op_worker_close");
+ core.jsonOpSync("op_worker_close");
}
function opStart() {
- return dispatchJson.sendSync("op_start");
+ return core.jsonOpSync("op_start");
}
function opMainModule() {
- return dispatchJson.sendSync("op_main_module");
- }
-
- function getAsyncHandler(opName) {
- switch (opName) {
- case "op_write":
- case "op_read":
- return dispatchMinimal.asyncMsgFromRust;
- default:
- return dispatchJson.asyncMsgFromRust;
- }
+ return core.jsonOpSync("op_main_module");
}
// TODO(bartlomieju): temporary solution, must be fixed when moving
@@ -159,7 +148,9 @@ delete Object.prototype.__proto__;
function initOps() {
const opsMap = core.ops();
for (const [name, opId] of Object.entries(opsMap)) {
- core.setAsyncHandler(opId, getAsyncHandler(name));
+ if (name === "op_write" || name === "op_read") {
+ core.setAsyncHandler(opId, dispatchMinimal.asyncMsgFromRust);
+ }
}
core.setMacrotaskCallback(timers.handleTimerMacrotask);
}