gistfile1.js

'use strict';

var stream = require('stream');

var timer = new stream.Readable({
   highWaterMark: 1,
   read: function() {
      console.log('read');
      var self = this;

      //console.log('called');
      setTimeout(function() {
         self.push('ping');
         //console.log('pushed');
      }, 100);
   }
});

timer.pipe(process.stdout);

setTimeout(function() {
   timer.unpipe(process.stdout);
   console.log('unpipe');
}, 500);