code: function Sink(callback) {
  
    _.bindAll(this);
  
    this._dataPackets = [];
  
    this.writable = true;
    this.callback = callback;
  
    this.on('err', this._onError);
  
    Stream.apply(this);
  }
docs: /* ========================================================================== *
  CONSTRUCTOR & INITIALIZATION                                              *
  ==========================================================================