onNext(rawRecord) {
    let record = new Record(this._fieldKeys, rawRecord, this._fieldLookup);
    if( this._observer ) {
      this._observer.onNext( record );
    } else {
      this._queuedRecords.push( record );
    }
  }
/**
   * Will be called on every record that comes in and transform a raw record
   * to a Object. If user-provided observer is present, pass transformed record
   * to it's onNext method, otherwise, push to record que.
   * @param {Array} rawRecord - An array with the raw record
   */
Will be called on every record that comes in and transform a raw record
to a Object. If user-provided observer is present, pass transformed record
to it's onNext method, otherwise, push to record que.
@param {Array} rawRecord - An array with the raw record
Will be called on every record that comes in and transform a raw record to a Object . If user - provided observer is present pass transformed record to it ' s onNext method otherwise push to record que . @param { Array } rawRecord - An array with the raw record
onNext(rawRecord) {
    let record = new Record(this._fieldKeys, rawRecord, this._fieldLookup);
    if( this._observer ) {
      this._observer.onNext( record );
    } else {
      this._queuedRecords.push( record );
    }
  }
onNext ( rawRecord ) { let record = new Record ( this . _fieldKeys , rawRecord , this . _fieldLookup ) ; if ( this . _observer ) { this . _observer . onNext ( record ) ; } else { this . _queuedRecords . push ( record ) ; } }
Will be called on every record that comes in and transform a raw record
 to a Object.
Will be called on every record that comes in and transform a raw record to a Object .