blob: 3ee20d711a924996d8c9cb92dc67ddfd75581098 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
|
object Test {
def main(args: Array[String]): Unit = {
import scala.concurrent._
import ExecutionContext.Implicits.global
val source1 = Promise[Int]()
val source2 = Promise[Int]()
val done = Promise[Unit]()
source2.completeWith(source1.future).future.onComplete {
case _ =>
print("success")
done.success(())
}
source2.tryFailure(new TimeoutException)
source1.success(123)
import duration._
Await.result(done.future, 120.seconds)
}
}
|