private[this] def readBatch()

in src/main/scala/com/twitter/iago/feeder/ParrotFeeder.scala [224:231]

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

  private[this] def readBatch(readSize: Int): List[String] = {
    log.debug("Reading %d log lines.", readSize)

    val result = for (i <- 1 to readSize if lines.hasNext) yield lines.next()

    requestsRead.addAndGet(result.size)
    result.toList
  }