Markdium-Orchestrating startup and shutdown in Scala

Markdium-Scala.scala

def stopService(service: Service): Task[Either[ServiceStopError, Service]] =
  Task.deferFuture {
    service.triggerStop()
    service.stopped.map(_.map(_ => service))
  }.timeout(duration).onErrorRecover {
    case _: TimeoutException => ServiceStopTimeoutError(service, duration).asLeft
  }