streaming-client.js

const grpc = require("grpc");
const {routeguide} = require("./routeguide");

const stub = new routeguide.Streaming(
  "localhost:2999",
  grpc.credentials.createInsecure(),
  // {channelOverride: 
  //   new grpc.Channel(
  //     "localhost:3000", 
  //     grpc.credentials.createInsecure(),
  //     )}
);

const stub2 = new routeguide.Streaming(
  "localhost:5555",
  grpc.credentials.createInsecure(),
  // {channelOverride: 
  //   new grpc.Channel(
  //     "localhost:3000", 
  //     grpc.credentials.createInsecure(),
  //     )}
);

// console.log(Object.keys(stub.__proto__.numberToNumber));
const interceptor = function(options, nextCall) {
  console.log("options:", options);
  var requester = {
    start: function(metadata, listener, next) {
      console.log("metadata start", metadata);
      var newListener = {
        onReceiveMetadata: function(metadata, next) {
          console.log("metadata on Receive meta", metadata);
          next(metadata);
        },
        onReceiveMessage: function(message, next) {
          console.log("metadata on Receive message", metadata);
          next(message);
        },
        onReceiveStatus: function(status, next) {
          console.log("metadata on receive status", metadata);
          next(status);
        }
      };
      next(metadata, newListener);
    },
    sendMessage: function(message, next) {
      console.log("sendmessage", message);
      next(message);
    },
    halfClose: function(next) {
      console.log("halfclose");
      next();
    },
    cancel: function(message, next) {
      console.log("cancel", message);
      next();
    }
  };
  return new grpc.InterceptingCall(nextCall(options), requester);
};

// console.log(grpc);
// const provider = grpc.InterceptorProvider(stub.numberToNumber.path);
// console.log(provider)

// console.log('path', stub.numberToNumber.path)

// stub.numberToNumber.interceptors.push(interceptor);

const ourNumber = {
  number: 4
};

const bidi = stub.bidiTwice();

bidi.write(ourNumber);
console.time("label");

//set event listener for readable stream
bidi.on("data", data => {
  console.log("data from og:", data);
  const { number } = data;
  bidi.write({ number: number });
});

bidi.on("end", () => {
  // console.log("end:", count);
  console.timeEnd("label");
});

const bidi2 = stub2.bidiTwice();

bidi2.write(ourNumber);
console.time("label2");

//set event listener for readable stream
bidi2.on("data", data => {
  console.log("data from server:", data);
  const { number } = data;
  bidi2.write({ number: number + 1 });
});
 
bidi2.on("end", () => {
  // console.log("end:", count);
  console.timeEnd("label2");
});

// console.log('bidiTwice', 54 / 399);