code: function() {
  
    stream.Readable.call(this, {highWaterMark: 102400});
  
    this._monitorState = {
      running: false,
      ended: false,
      streamBuffering: true,
      interval: undefined,
      config: _.clone(defaults)
    };
  }
docs: constructor