Markdium-Orchestrating startup and shutdown in Scala

Markdium-Scala.scala

import scala.concurrent.{ ExecutionContext, Future, Promise }  

/**
 * Stoppable[T]: represents a process with a 
 * termination function of type `T`
 */   
trait Stoppable[T] {  
  protected implicit def executionContext: ExecutionContext  
  private val stoppedPromise = Promise[T]()  
  private val stopTriggeredPromise = Promise[Unit]()  
  
  /**  
   * Notify we have been stopped
   * @param stopResult Result of stop operation  
   */  
   protected def notifyStopped(stopResult: T): Unit =    stoppedPromise.trySuccess(stopResult)
  
  /**  
   * Watch for stop operation completion
   * @return Returned Future will complete with stop result upon stop  
   */  
   def stopped: Future[T] = stoppedPromise.future  
  
  /**  
   * Trigger stop: this only emits a notification in [[stopTriggered]]  
   */  
   def triggerStop(): Unit = stopTriggeredPromise.trySuccess(())  
  
  /**  
   * Watch for stop triggers  
   * @return Returned Future will complete with unit upon stop triggered by a call to [[triggerStop]]  
   */  
   def stopTriggered: Future[Unit] = stopTriggeredPromise.future  
}