diff options
| author | Ryan Dahl <ry@tinyclouds.org> | 2019-08-21 20:42:48 -0400 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-08-21 20:42:48 -0400 |
| commit | bdc97b3976786bb744a27e59b0f4f28554a682df (patch) | |
| tree | bf4635ad903de542c10620e95adb72eee03d9204 /js/process.ts | |
| parent | b764d1b8ffc4bf5e2ab89bdbd978d708a6da0f24 (diff) | |
Organize dispatch a bit (#2796)
Just some clean up reorganization around flatbuffer/minimal dispatch
code. This is prep for adding a JSON dispatcher.
Diffstat (limited to 'js/process.ts')
| -rw-r--r-- | js/process.ts | 10 |
1 files changed, 4 insertions, 6 deletions
diff --git a/js/process.ts b/js/process.ts index 0629b26b0..b2b6d4734 100644 --- a/js/process.ts +++ b/js/process.ts @@ -1,7 +1,5 @@ // Copyright 2018-2019 the Deno authors. All rights reserved. MIT license. -import * as dispatch from "./dispatch"; -import * as flatbuffers from "./flatbuffers"; -import * as msg from "gen/cli/msg_generated"; +import { sendSync, sendAsync, msg, flatbuffers } from "./dispatch_flatbuffers"; import { File, close } from "./files"; import { ReadCloser, WriteCloser } from "./io"; @@ -37,7 +35,7 @@ async function runStatus(rid: number): Promise<ProcessStatus> { const builder = flatbuffers.createBuilder(); const inner = msg.RunStatus.createRunStatus(builder, rid); - const baseRes = await dispatch.sendAsync(builder, msg.Any.RunStatus, inner); + const baseRes = await sendAsync(builder, msg.Any.RunStatus, inner); assert(baseRes != null); assert(msg.Any.RunStatusRes === baseRes!.innerType()); const res = new msg.RunStatusRes(); @@ -60,7 +58,7 @@ async function runStatus(rid: number): Promise<ProcessStatus> { export function kill(pid: number, signo: number): void { const builder = flatbuffers.createBuilder(); const inner = msg.Kill.createKill(builder, pid, signo); - dispatch.sendSync(builder, msg.Any.Kill, inner); + sendSync(builder, msg.Any.Kill, inner); } export class Process { @@ -227,7 +225,7 @@ export function run(opt: RunOptions): Process { stdoutRidOffset, stderrRidOffset ); - const baseRes = dispatch.sendSync(builder, msg.Any.Run, inner); + const baseRes = sendSync(builder, msg.Any.Run, inner); assert(baseRes != null); assert(msg.Any.RunRes === baseRes!.innerType()); const res = new msg.RunRes(); |
