def doAtLeastOneMore()

in app/lib/Dogpile.scala [49:61]

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

  def doAtLeastOneMore(): Future[R] = stateRef.updateAndGet { // TODO updateAndGet shouldn't handle side-effects
    previousState =>
    if (previousState.scanFuture.isCompleted) ScanRun(thing) else {
      previousState match {
        case ScanQueued(_) => previousState
        case ScanRun(s) => {
          val p = Promise[R]()
          s.onComplete(_ => p.completeWith(thing))
          ScanQueued(p.future)
        }
      }
    }
  }.scanFuture