def next()

in src/main/scala/com/twitter/iago/feeder/LzoFileLogSource.scala [37:48]

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

  def next(): String = source.next()
  def hasNext: Boolean = source.hasNext

  def reset() {
    try {
      decompressedStream.close()
    } catch {
      case e: Throwable =>
        log.warning("Exception %s thrown while closing the log %s", e, filename)
    }
    source = init()
  }