Markdium-Orchestrating startup and shutdown in Scala

Markdium-Scala.scala

class ClusterUpAndServiceBoundCheck(system: ActorSystem) extends (() => Future[Boolean]) {
  private val cluster = Cluster(system)
  discard {
    CoordinatedShutdown(system).serviceUnbind(
      () =>
        Future.successful {
          serviceUnbound.set(true)
          Done
        },
      "service-unbound-check"
    )
  }
  private val serviceUnbound = new AtomicBoolean(false)

  override def apply(): Future[Boolean] =
    Future.successful(cluster.selfMember.status match {
      case MemberStatus.Up => !serviceUnbound.get()
      case _               => false
    })
}