grpc/flatbuffers-js-grpc/src/client.ts


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

import grpc from 'grpc';
import { HelloRequest } from './greeter_generated';
import { GreeterClient } from './greeter_grpc';
import { flatbuffers } from 'flatbuffers';

async function main() {
    const _server = new GreeterClient('localhost:3000', grpc.credentials.createInsecure());
    const builder = new flatbuffers.Builder();
    const offset = builder.createString('mustii');
    const root = HelloRequest.createHelloRequest(builder, offset);
    builder.finish(root);
    const buffer = HelloRequest.getRootAsHelloRequest(new flatbuffers.ByteBuffer(builder.asUint8Array()));

    _server.SayHello(buffer, (err, response) => {
        console.log(response.message());
    });

    const data = _server.SayManyHellos(buffer, null);

    data.on('data', (data) => {
        console.log(data.message());
    });
    data.on('end', (data) => {
        console.log('end');
    });
}

main();