Robust Stream Processing with pipeline()

Snippet

Robust Stream Processing with pipeline()

The pipeline utility is a cleaner and safer alternative to .pipe(), as it handles error propagation and stream cleanup automatically, preventing memory leaks.

snippet.js
javascript
const { pipeline } = require('node:stream/promises');
const { createReadStream, createWriteStream } = require('node:fs');
 
async function compressLogs() {
  try {
    await pipeline(
      createReadStream('access.log'),
      createWriteStream('access.log.bak')
    );
    console.log('Pipeline succeeded');
  } catch (err) {
    console.error('Pipeline failed:', err);
  }
}

nodejs

Breakdown

require('node:stream/promises')

Imports the promise-based version of the stream module for use with async/await.

await pipeline(...)

Sequentially connects multiple streams and waits for the entire process to finish or fail.

Previous snippet Next snippet

More Intermediate JavaScript exercises →

From your library

Robust Stream Processing with pipeline()

Related