private def shouldClose()

in pekko-sample-persistence-dc-scala/src/main/scala/sample/persistence/res/auction/Auction.scala [129:143]

• 15 lines of code
• 5 McCabe index (conditional complexity)

  private def shouldClose(state: AuctionState): Boolean = {
    responsibleForClosing && (state.phase match {
      case Closing(alreadyFinishedAtDc) =>
        val allDone = MainApp.AllReplicas.diff(alreadyFinishedAtDc).isEmpty
        if (!allDone) {
          context.log.info2(
            s"Not closing auction as not all DCs have reported finished. All DCs: {}. Reported finished {}",
            MainApp.AllReplicas,
            alreadyFinishedAtDc)
        }
        allDone
      case _ =>
        false
    })
  }