diff options
author | Bartek IwaĆczuk <biwanczuk@gmail.com> | 2020-09-16 22:22:43 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-09-16 22:22:43 +0200 |
commit | 6c4da0e429eb47dae6a220c5576a39f137615bb8 (patch) | |
tree | a8715428caea00105acc9a10fcd0f356085d3fa7 /cli/rt/99_main.js | |
parent | 104aebdfb5d01f7482bacef6d58c2ce16da44334 (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.js | 23 |
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); } |