Using pipe to connect multiple streams

Part of the Stream API, the pipe function is a precious tool used to wire multiple streams. The function is meant to connect a stream.Readable source to a stream.Writable destination.

The pipe example reads a file, parses its content, transforms it and print the result to the standard output.

This example is available with the command node samples/recipe.pipe.js.

import { parse } from 'csv-parse';
import { generate } from 'csv-generate';
import { transform } from 'stream-transform';

const generator = generate({
  length: 20
});
const parser = parse({
  delimiter: ':'
});
const transformer = transform((record, callback) => {
  setTimeout(() => {
    callback(null, record.join(' ')+'\n');
  }, 500);
}, {
  parallel: 5
});
generator.pipe(parser).pipe(transformer).pipe(process.stdout);

./packages/csv-parse/samples/recipe.pipe.js