Markdium-Orchestrating startup and shutdown in Scala

Markdium-Scala.scala

 Observable  
  .fromTask(startTriggered)  
  .ambWith(Observable.fromTask(stopTriggered))  
  .flatMap(_ =>  
	 Observable  
	  .fromIterable(services)  
	  .takeUntil(Observable.fromTask(stopTriggered))  
	  .mapEval(startService)  
	  .map(_.asRight)  
	  .onErrorHandleWith { 
		  case failure: ServiceStartFailed => Observable(failure.error.asLeft) 
	   }  
	  .takeWhileInclusive(_.isRight)  
	  .scan(StartResults.empty)(  
		 (results, lastStartResult) =>  
		  lastStartResult match {  
		  case Left(failure) => results.copy(failure = Some(failure))  
		  case Right(service)=> 
			  registerForServiceStopOrError(service, triggerStop)  
			  results.copy(startedServices = results.startedServices :+ service)  
		} 
	): Observable[StartResults]