mirror of
https://github.com/google/flatbuffers.git
synced 2026-06-07 13:53:38 +00:00
* Updates go lang support to allow other languages to communicate with it * Update js grpc lib to use grpc-js Reformat code
34 lines
1.1 KiB
TypeScript
34 lines
1.1 KiB
TypeScript
import * as grpc from '@grpc/grpc-js';
|
|
import * as flatbuffers from 'flatbuffers';
|
|
import { HelloReply } from './models/hello-reply';
|
|
import { HelloRequest } from './models/hello-request';
|
|
import { GreeterClient } from './greeter_grpc';
|
|
|
|
async function main(PORT: Number, name: string) {
|
|
const client = new GreeterClient(`localhost:${PORT}`, grpc.credentials.createInsecure());
|
|
const builder = new flatbuffers.Builder();
|
|
const offset = builder.createString(name);
|
|
const root = HelloRequest.createHelloRequest(builder, offset);
|
|
builder.finish(root);
|
|
const buffer = HelloRequest.getRootAsHelloRequest(new flatbuffers.ByteBuffer(builder.asUint8Array()));
|
|
|
|
client.SayHello(buffer, (err, response) => {
|
|
console.log(response.message());
|
|
});
|
|
|
|
const data = client.SayManyHellos(buffer, null);
|
|
|
|
data.on('data', (data) => {
|
|
console.log(data.message());
|
|
});
|
|
}
|
|
|
|
const args = process.argv.slice(2)
|
|
const PORT = Number(args[0]);
|
|
const name: string = args[1] ?? "flatbuffers";
|
|
|
|
if (PORT) {
|
|
main(PORT, name);
|
|
} else {
|
|
throw new Error("Requires a valid port number.")
|
|
} |