import scala.concurrent._



object Test extends App {

  def once(body: (() => Unit) => Unit) {
    val sv = new SyncVar[Boolean]
    body(() => sv put true)
    sv.take()
  }

  def output(num: Int, msg: String) {
    println("test" + num + ": " + msg)
  }

  def testOnSuccess(): Unit = once {
    done =>
    val f = future {
      output(1, "hai world")
    }
    f onSuccess { case _ =>
      output(1, "kthxbye")
      done()
    }
  }

  def testOnSuccessWhenCompleted(): Unit = once {
    done =>
    val f = future {
      output(2, "hai world")
    }
    f onSuccess { case _ =>
      output(2, "awsum thx")
      f onSuccess { case _ =>
        output(2, "kthxbye")
        done()
      }
    }
  }

  def testOnSuccessWhenFailed(): Unit = once {
    done =>
    val f = future[Unit] {
      output(3, "hai world")
      done()
      throw new Exception
    }
    f onSuccess { case _ =>
      output(3, "onoes")
    }
  }

  def testOnFailure(): Unit = once {
    done =>
    val f = future[Unit] {
      output(4, "hai world")
      throw new Exception
    }
    f onSuccess { case _ =>
      output(4, "onoes")
      done()
    }
    f onFailure { case _ =>
      output(4, "kthxbye")
      done()
    }
  }

  def testOnFailureWhenSpecialThrowable(num: Int, cause: Throwable): Unit = once {
    done =>
    val f = future[Unit] {
      output(num, "hai world")
      throw cause
    }
    f onSuccess { case _ =>
      output(num, "onoes")
      done()
    }
    f onFailure {
      case e: ExecutionException if (e.getCause == cause) =>
        output(num, "kthxbye")
        done()
      case _ =>
        output(num, "onoes")
        done()
    }
  }

  // def testOnFailureWhenFutureTimeoutException(): Unit = once {
  //   done =>
  //   val f = future[Unit] {
  //     output(8, "hai world")
  //     throw new FutureTimeoutException(null)
  //   }
  //   f onSuccess { case _ =>
  //     output(8, "onoes")
  //     done()
  //   }
  //   f onFailure {
  //     case e: FutureTimeoutException =>
  //       output(8, "im in yr loop")
  //       done()
  //     case other =>
  //       output(8, "onoes: " + other)
  //       done()
  //   }
  // }

  testOnSuccess()
  testOnSuccessWhenCompleted()
  testOnSuccessWhenFailed()
  testOnFailure()
  testOnFailureWhenSpecialThrowable(5, new Error)
  testOnFailureWhenSpecialThrowable(6, new scala.util.control.ControlThrowable { })
  testOnFailureWhenSpecialThrowable(7, new InterruptedException)
  // testOnFailureWhenFutureTimeoutException()

}