code: function Bolt(options) {
  
    _.bindAll(this);
  
    this.writable = true;
    this.readable = true;
  
    this.options = _.extend({ limit : Infinity }, this.options, options);
  
    this._processing = 0;
    this._pendingQueue = [];
    this._emissionQueue = [];
  
    Stream.apply(this);
  }
docs: /* ========================================================================== *
  CONSTRUCTOR & INITIALIZATION                                              *
  ==========================================================================