lib/Kowalski.js
/**
   * Used by Readable for data streaming
   */
Used by Readable for data streaming
Used by Readable for data streaming
_read () {
    this.reading = true
    while (this.reading && this.infoBuffer.length) {
      this.reading = this.push(this.infoBuffer.shift())
      if (!this.reading) return
    }
  }
_read ( ) { this . reading = true while ( this . reading && this . infoBuffer . length ) { this . reading = this . push ( this . infoBuffer . shift ( ) ) if ( ! this . reading ) return } }
Used by Readable for data streaming
Used by Readable for data streaming
// First empty the buffer // Now the middleware will push live data