rxjs-grpc-minimal

import grpc from '@grpc/grpc-js'; import protoLoader from '@grpc/proto-loader'; import { toRxClient, toRxServer } from 'rxjs-grpc-minimal'; import { of, Observable, Subject } from 'rxjs'; // 1. Load proto const packageDefinition = protoLoader.loadSync('./helloworld.proto', { keepCase: false, longs: String, enums: String, defaults: true, oneofs: true }); const proto = grpc.loadPackageDefinition(packageDefinition).helloworld; // 2. Create RxJS client (wrapping proto) const RxClient = toRxClient(proto); // 3. Instantiate client const greeter = new RxClient.Greeter('localhost:50051', grpc.credentials.createInsecure()); // 4. Make unary call await greeter.sayHelloRx({ name: 'World' }).forEach((resp: { message: string }) => { console.log(resp.message); // 'Hello World!' }); // 5. Create RxJS server implementation const rxImpl = { sayHello({ value: { name } }: { value: { name: string } }) { return of({ message: `Hello ${name}!` }); }, sayMultiHello({ value: { name, numGreetings } }: { value: { name: string; numGreetings: number } }) { return new Observable((observer) => { for (let i = 0; i < numGreetings; i++) { observer.next({ message: `Hello ${name} (${i + 1})` }); } observer.complete(); }); } }; const server = new grpc.Server(); const rxServer = toRxServer(server, 'helloworld.Greeter', rxImpl); server.bindAsync('0.0.0.0:50051', grpc.ServerCredentials.createInsecure(), () => { server.start(); });