source.pipe(through(function (chunk) {
  var self = this;
  console.log('start');
  self.pause();
  setTimeout(function () {
    console.log('end');
    self.resume();
  }, 1000);
})
.pipe(process.stdout);