kevinsimper

var stream = require('stream');
 
var timer = new stream.Readable({
   read: function() {
      var self = this;
 
      console.log('called');
      setTimeout(function() {
          if(!timer.isPaused()){
           self.push('ping\n');