const nodeReadableStream = getReadableStream(); // Get a Node.js Readable stream somehow
 
// Create a ReadableStream instance, based on the nodeReadableStream underlying source.
const stream = new ReadableStream({
  start(controller) {
    nodeReadableStream.pause();
    nodeReadableStream.on('data', (chunk) => {
      controller.enqueue(chunk);
      nodeReadableStream.pause();
    });
    nodeReadableStream.once('end', () => controller.close());
    nodeReadableStream.once('error', (e) => controller.error(e));
  },
  pull(controller) {
    nodeReadableStream.resume();
  },
  cancel() {
    nodeReadableStream.destroy();
  }
});
 
// Get a Reader for the stream.
const reader = stream.getReader();
 
// Start reading from the reader.
doReadEverything();
 
// Function that reads from the reader, consuming all data.
async function doReadEverything() {
  let value;
  let done = false;
 
  while (!done) {
    ({value, done} = await reader.read());
 
    // Do something with value, if `done` is still not `true`
  }
 
  // Finished reading. Do something
}