transform-with-pause.js

var util = require('util');
var Transform = require('stream').Transform;

var MyTransformKlass = function(){
  Transform.apply(this,arguments);
  this.pause();
  setTimeout(function imAsync(){
    this.resume();
  }.bind(this), 30000);
};

util.inherits(MyTransformKlass, Transform);

MyTransform.prototype._transform = function(data,enc,cb){
  // do stuff
  cb();
};

module.exports = MyTransformKlass;