changeProcessor._flush = function()

in lib/changesreader.js [64:69]

• 6 lines of code
• 2 McCabe index (conditional complexity)

  changeProcessor._flush = function (done) {
    if (buffer.length > 0) {
      ee.emit(EVENT_BATCH, buffer.splice(0, buffer.length))
    }
    done()
  }