def stopCs()

in pekko-connectors-sample-jms/src/main/scala/playground/ActiveMqBroker.scala [36:47]

• 11 lines of code
• 1 McCabe index (conditional complexity)

  def stopCs(ec: ExecutionContext): CompletionStage[Done] = stop()(ec).asJava

  def stop()(implicit ec: ExecutionContext): Future[Done] =
    brokerService.fold(Future.successful(Done)) { broker =>
      Future {
        broker.stop()
        scala.concurrent.blocking {
          broker.waitUntilStopped()
        }
        Done
      }
    }