bl-test.js

var BufferedList = require('bl');
 
var source = new BufferedList(),
    middle = new BufferedList();
 
//
// Buffer a bunch of strings.
//
for (var i = 0; i < 1000; i++) {
  source.append('push: ' + i + '\n');
}
 
//
// Simulate async behavior...
//
console.log('waiting ...')
setTimeout(function () {
  //
  // Ensure the duplex actually emits "end"
  //
  middle.on('end', function () {
    console.log('emitted end');
  });
  
  //
  // Pipe it somewhere.
  //
  source.pipe(middle);
  process.nextTick(function () {
    middle.pipe(process.stdout);
  });
}, 2000);