summaryrefslogtreecommitdiff
path: root/js/dispatch.ts
diff options
context:
space:
mode:
Diffstat (limited to 'js/dispatch.ts')
-rw-r--r--js/dispatch.ts42
1 files changed, 21 insertions, 21 deletions
diff --git a/js/dispatch.ts b/js/dispatch.ts
index 55ea682fc..537291877 100644
--- a/js/dispatch.ts
+++ b/js/dispatch.ts
@@ -10,11 +10,11 @@ const promiseTable = new Map<number, util.Resolvable<msg.Base>>();
let fireTimers: () => void;
-export function setFireTimersCallback(fn: () => void) {
+export function setFireTimersCallback(fn: () => void): void {
fireTimers = fn;
}
-export function handleAsyncMsgFromRust(ui8: Uint8Array) {
+export function handleAsyncMsgFromRust(ui8: Uint8Array): void {
// If a the buffer is empty, recv() on the native side timed out and we
// did not receive a message.
if (ui8 && ui8.length) {
@@ -35,6 +35,25 @@ export function handleAsyncMsgFromRust(ui8: Uint8Array) {
fireTimers();
}
+function sendInternal(
+ builder: flatbuffers.Builder,
+ innerType: msg.Any,
+ inner: flatbuffers.Offset,
+ data: undefined | ArrayBufferView,
+ sync = true
+): [number, null | Uint8Array] {
+ const cmdId = nextCmdId++;
+ msg.Base.startBase(builder);
+ msg.Base.addInner(builder, inner);
+ msg.Base.addInnerType(builder, innerType);
+ msg.Base.addSync(builder, sync);
+ msg.Base.addCmdId(builder, cmdId);
+ builder.finish(msg.Base.endBase(builder));
+ const res = libdeno.send(builder.asUint8Array(), data);
+ builder.inUse = false;
+ return [cmdId, res];
+}
+
// @internal
export function sendAsync(
builder: flatbuffers.Builder,
@@ -68,22 +87,3 @@ export function sendSync(
return baseRes;
}
}
-
-function sendInternal(
- builder: flatbuffers.Builder,
- innerType: msg.Any,
- inner: flatbuffers.Offset,
- data: undefined | ArrayBufferView,
- sync = true
-): [number, null | Uint8Array] {
- const cmdId = nextCmdId++;
- msg.Base.startBase(builder);
- msg.Base.addInner(builder, inner);
- msg.Base.addInnerType(builder, innerType);
- msg.Base.addSync(builder, sync);
- msg.Base.addCmdId(builder, cmdId);
- builder.finish(msg.Base.endBase(builder));
- const res = libdeno.send(builder.asUint8Array(), data);
- builder.inUse = false;
- return [cmdId, res];
-}