Using node Readline.createInterface in a pipeline

readline-pipeline.md

pipeline accepts a function which receives the source as an argument and expects it to return a promise or async iterator, and the Interface object returned by Readline.createInterface can be used as an async iterator, so you can do this:

import { pipeline } from "node:stream";
import { createInterface } from "node:readline";

pipeline(
  process.stdin,
  (input) => createInterface({ input }),
  process.stdout,
  (err) => {
    if (err) {
      console.error('Pipeline failed.', err);
    } else {
      console.log('Pipeline succeeded.');
    }
  }
);

You could also wrap it to make it easier to reuse/setup options:

import { pipeline } from "node:stream";
import { createInterface } from "node:readline";

function createReadlineIterator(options = { crlfDelay: Infinity }) {
  return (input) => createInterface({
    input,
    ...options
  });
}

pipeline(
  process.stdin,
  createReadlineIterator(),
  process.stdout,
  (err) => {
    if (err) {
      console.error('Pipeline failed.', err);
    } else {
      console.log('Pipeline succeeded.');
    }
  }
);