Markdium-Orchestrating startup and shutdown in Scala

Markdium-Scala.scala

object CoordinatedShutdownHttpHelpers {
  implicit class FluentHttpCoordinatedShutdown(coordinatedShutdown: CoordinatedShutdown)(
    implicit val system: ActorSystem
  ) {
    private implicit val executionContext: ExecutionContext = system.dispatcher

    def addHttpBinding(
      binding: Http.ServerBinding,
      pendingRequestsHardDeadline: FiniteDuration,
      unbindingDelay: FiniteDuration
    ): CoordinatedShutdown = {
      val addressAndPort = s"${binding.localAddress.getHostString}:${binding.localAddress.getPort}"
      coordinatedShutdown
        .serviceUnbind(
          () => akka.pattern.after(unbindingDelay, system.scheduler)(binding.unbind()),
          s"http-unbind-$addressAndPort"
        )
        .serviceRequestsDone(
          () => binding.terminate(pendingRequestsHardDeadline).map(_ => Done),
          s"http-graceful-terminate-$addressAndPort"
        )
        .serviceStop(() => Http().shutdownAllConnectionPools().map(_ => Done), s"http-done-$addressAndPort")
    }
  }
}