Not compatible with protobufjs 6.7.x about rxjs-grpc HOT 11 CLOSED

import { Observable } from 'rxjs';
import { serverBuilder } from 'rxjs-grpc';
import { sample } from './grpc-namespaces';

async function main() {
  type ServerBuilder = sample.ServerBuilder;
  const server = serverBuilder<ServerBuilder>('sample.proto', 'sample');

  server.addGreeter({

    sayHello(request) {
      return Observable.of({
        message: 'Hello ' + request.name
      });
    },

    sayMultiHello(request) {
      return Observable.timer(100, 500)
        .mapTo({ message: `Hello ${request.name}` })
        .take(request.num_greetings);
    }

  });

  server.start('0.0.0.0:50051');
}

main().catch(error => console.error(error));

import { clientFactory } from 'rxjs-grpc';
import { sample } from './grpc-namespaces';

async function main() {
  type ClientFactory = sample.ClientFactory;
  const Services = clientFactory<ClientFactory>('sample.proto', 'sample');

  const services = new Services('localhost:50051');
  const greeter = services.getGreeter();

  await greeter.sayMultiHello({ name: 'world', num_greetings: 3 }).forEach(response => {
    console.log(`Multi greeting: ${response.message}`);
  });

  await greeter.sayHello({ name: 'world' }).forEach(response => {
    console.log(`Greeting: ${response.message}`);
  });

}

main().catch(error => console.error(error));