waitForSIGTERM.scala

def waitForSIGTERM(cv: AnyRef = new Object()) {
  Runtime.getRuntime.addShutdownHook(
    new Thread(() => cv.synchronized(cv.notify()))
  )
  @tailrec
  def loop(): Unit = try cv.synchronized(cv.wait())
  catch {
    case _: InterruptedException => loop()
  }
  loop()
}