Markdium-Orchestrating startup and shutdown in Scala

Markdium-Scala.scala

"notify stopped with error in case of service stop timeout" in {
      implicit val scheduler = TestScheduler()
      val serviceA = Service.withName("A").withStopper(() => Future.never).build
      val serviceB = Service.withName("B").withStopper(() => Future.successful(())).build

      Given("a started composite with finite stopped timeout")
      implicit val stoppedTimeout = FiniteStoppedTimeout(30 seconds)
      val composite               = new CompositeService(serviceA, serviceB)
      composite.start()
      scheduler.tick(1 second)

      When("stopping the composite")
      composite.triggerStop()

      Then("composite eventually notifies stopped with errors")
      scheduler.tick(31 seconds) // this simulates 31 seconds elapsing
      composite.stopped.futureValue shouldBe left
    }
  }