RPC example with backpressure, timeout and stop

streaming-rpc-example.js

const file = await rabbit.getReply(‘readFile’, {
  correlationId,
  headers: { backpressure: true, timeout: 1000 },
});

for await (const line of file) {
  console.log(line);
  process(line);
  if(processingHasFinished()) {
    // send stop signal to producer of the stream which is a different microservice
    file.emit(rabbit.constructor.STOP_STREAM);
  }
}