override def next()

in src/main/scala/com/spotify/bdrc/pipeline/Sessions.scala [42:53]

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

    override def next(): Seq[LogEvent] = {
      val buf = mutable.Buffer(bi.next())
      var last = buf.head.timestamp

      // Consume subsequent events until a gap is detected
      while (bi.hasNext && bi.head.timestamp - last < gapDuration) {
        val n = bi.next()
        buf.append(n)
        last = n.timestamp
      }
      buf
    }