diff options
author | Ryan Dahl <ry@tinyclouds.org> | 2018-10-17 13:04:28 -0400 |
---|---|---|
committer | Ryan Dahl <ry@tinyclouds.org> | 2018-10-17 20:20:06 -0400 |
commit | 213885a9d00a913e3fd2eb21a5992efb63c888f5 (patch) | |
tree | 7ac1c5ffad1c3125d72155e40ef5ea75c39945ba /js/net.ts | |
parent | 4e2e185de74edaf49d77983c935686616ba9d07c (diff) |
Optimization: Reuse ArrayBuffer during serialization.
Diffstat (limited to 'js/net.ts')
-rw-r--r-- | js/net.ts | 10 |
1 files changed, 5 insertions, 5 deletions
@@ -4,7 +4,7 @@ import { ReadResult, Reader, Writer, Closer } from "./io"; import * as msg from "gen/msg_generated"; import { assert, notImplemented } from "./util"; import * as dispatch from "./dispatch"; -import { flatbuffers } from "flatbuffers"; +import * as flatbuffers from "./flatbuffers"; import { read, write, close } from "./files"; export type Network = "tcp"; @@ -32,7 +32,7 @@ class ListenerImpl implements Listener { constructor(readonly rid: number) {} async accept(): Promise<Conn> { - const builder = new flatbuffers.Builder(); + const builder = flatbuffers.createBuilder(); msg.Accept.startAccept(builder); msg.Accept.addRid(builder, this.rid); const inner = msg.Accept.endAccept(builder); @@ -111,7 +111,7 @@ enum ShutdownMode { } function shutdown(rid: number, how: ShutdownMode) { - const builder = new flatbuffers.Builder(); + const builder = flatbuffers.createBuilder(); msg.Shutdown.startShutdown(builder); msg.Shutdown.addRid(builder, rid); msg.Shutdown.addHow(builder, how); @@ -136,7 +136,7 @@ function shutdown(rid: number, how: ShutdownMode) { * See `dial()` for a description of the network and address parameters. */ export function listen(network: Network, address: string): Listener { - const builder = new flatbuffers.Builder(); + const builder = flatbuffers.createBuilder(); const network_ = builder.createString(network); const address_ = builder.createString(address); msg.Listen.startListen(builder); @@ -179,7 +179,7 @@ export function listen(network: Network, address: string): Listener { * dial("tcp", ":80") */ export async function dial(network: Network, address: string): Promise<Conn> { - const builder = new flatbuffers.Builder(); + const builder = flatbuffers.createBuilder(); const network_ = builder.createString(network); const address_ = builder.createString(address); msg.Dial.startDial(builder); |