private[this] def runNewBatches()

in src/main/scala/com/twitter/stitch/Pending.scala [161:180]

• 17 lines of code
• 4 McCabe index (conditional complexity)

  private[this] def runNewBatches(): Unit = {
    var i = 0
    val runners = runnersByGroup.values.toArray(Run.emptyRunnerArray)
    runnersByGroup.clear()

    while (i < runners.length) {
      runners(i) match {
        case runner: FutureRunner[_, _] =>
          val f = runner.run()
          futures += f
          f.respond(loopCallback)

        case runner: StitchRunner[_, _] =>
          runner.run()
          // increment nwaiters to force another loop run
          nwaiters.getAndIncrement()
      }
      i += 1
    }
  }