blob: 649543f9d8d748a50db1c17023daf12317060bed (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
|
/*
* Copyright (C) 2012-2014 Lightbend Inc. <http://www.lightbend.com>
*/
package scala.async
package run
package exceptions
import scala.async.Async.{async, await}
import scala.concurrent.{Future, ExecutionContext, Await}
import ExecutionContext.Implicits._
import scala.concurrent.duration._
import scala.reflect.ClassTag
import org.junit.Test
class ExceptionsSpec {
@Test
def `uncaught exception within async`() {
val fut = async { throw new Exception("problem") }
intercept[Exception] { Await.result(fut, 2.seconds) }
}
@Test
def `uncaught exception within async after await`() {
val base = Future { "five!".length }
val fut = async {
val len = await(base)
throw new Exception(s"illegal length: $len")
}
intercept[Exception] { Await.result(fut, 2.seconds) }
}
@Test
def `await failing future within async`() {
val base = Future[Int] { throw new Exception("problem") }
val fut = async {
val x = await(base)
x * 2
}
intercept[Exception] { Await.result(fut, 2.seconds) }
}
@Test
def `await failing future within async after await`() {
val base = Future[Any] { "five!".length }
val fut = async {
val a = await(base.mapTo[Int]) // result: 5
val b = await((Future { (a * 2).toString }).mapTo[Int]) // result: ClassCastException
val c = await(Future { (7 * 2).toString }) // result: "14"
b + "-" + c
}
intercept[ClassCastException] { Await.result(fut, 2.seconds) }
}
}
|
