RPC with streams example

a.get-local-file.js

// Reading a local file into a stream
const readStream = fs.createReadStream('file.txt');

b.read-file-handler.js

// The corresponding solution to read a file using a different microservice. (Hypothetical example)

// Reading a local file and exposing this as RPC service

rabbit.createQueue('readFile', { durable: false }, (msg, ack) => {
  const readStream = fs.createReadStream(msg.content().toString());
  ack(null, readStream);
});

c.get-remote-file.js

// Requesting a remote file with an RPC call

const readStream = await rabbit.getReply('readFile', 'file.txt');