Node.js stream pipeline

import { pipeline } from 'stream/promises';

await pipeline(
  readableStream,
  transformStream,
  writableStream
);

// No need to handle cleanup manually!