diff options
Diffstat (limited to 'js/dispatch.ts')
-rw-r--r-- | js/dispatch.ts | 42 |
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]; -} |