raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Adding tests for the chaining

Browse source
This commit is contained in:
Viktor Klang 2012-01-17 15:36:24 +01:00
parent 24a6a66ca0
commit a019c9e8a6
1 changed files with 9 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

11
akka-actor-tests/src/test/scala/akka/dispatch/FutureSpec.scala
View file

@ -49,11 +49,18 @@ class FutureSpec extends AkkaSpec with Checkers with BeforeAndAfterAll with Defa
"never completed" must {
behave like emptyFuture(_(Promise()))
"return supplied value on timeout" in {
val f = new RuntimeException("br0ken")
val timedOut = Promise.successful[String]("Timedout")
val promise = Promise.failed[String](new RuntimeException("br0ken")) or timedOut
val promise1 = Promise.failed[String](f) or timedOut
val promise2 = timedOut or Promise[String]()
Await.result(promise, timeout.duration) must be("Timedout")
val promise3 = Promise.failed[String](f) or Promise.failed[String](f) or timedOut
val promise4 = Promise.failed[String](f) or Promise.failed[String](new RuntimeException("last"))
Await.result(promise1, timeout.duration) must be("Timedout")
Await.result(promise2, timeout.duration) must be("Timedout")
Await.result(promise3, timeout.duration) must be("Timedout")
intercept[RuntimeException] {
Await.result(promise4, timeout.duration)
}.getMessage must be("last")
}
}
"completed with a result" must {