blob: b567ee66d7fd71decaf7bcdddbc8330fc5c06fa9 (
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
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
|
/*
* Copyright (C) 2012 Typesafe Inc. <http://www.typesafe.com>
*/
package scala.async
package run
package ifelse1
import language.{reflectiveCalls, postfixOps}
import scala.concurrent.{Future, ExecutionContext, future, Await}
import scala.concurrent.duration._
import scala.async.Async.{async, await}
import org.junit.runner.RunWith
import org.junit.runners.JUnit4
import org.junit.Test
class TestIfElse1Class {
import ExecutionContext.Implicits.global
def base(x: Int): Future[Int] = future {
x + 2
}
def m1(y: Int): Future[Int] = async {
val f = base(y)
var z = 0
if (y > 0) {
if (y > 100)
5
else {
val x1 = await(f)
z = x1 + 2
}
} else {
val x2 = await(f)
z = x2 - 2
}
z
}
def m2(y: Int): Future[Int] = async {
val f = base(y)
var z = 0
if (y > 0) {
if (y < 100) {
val x1 = await(f)
z = x1 + 2
}
else
5
} else {
val x2 = await(f)
z = x2 - 2
}
z
}
def m3(y: Int): Future[Int] = async {
val f = base(y)
var z = 0
if (y < 0) {
val x2 = await(f)
z = x2 - 2
} else {
if (y > 100)
5
else {
val x1 = await(f)
z = x1 + 2
}
}
z
}
def m4(y: Int): Future[Int] = async {
val f = base(y)
var z = 0
if (y < 0) {
val x2 = await(f)
z = x2 - 2
} else {
if (y < 100) {
val x1 = await(f)
z = x1 + 2
} else
5
}
z
}
}
@RunWith(classOf[JUnit4])
class IfElse1Spec {
@Test
def `await in a nested if-else expression`() {
val o = new TestIfElse1Class
val fut = o.m1(10)
val res = Await.result(fut, 2 seconds)
res mustBe (14)
}
@Test
def `await in a nested if-else expression 2`() {
val o = new TestIfElse1Class
val fut = o.m2(10)
val res = Await.result(fut, 2 seconds)
res mustBe (14)
}
@Test
def `await in a nested if-else expression 3`() {
val o = new TestIfElse1Class
val fut = o.m3(10)
val res = Await.result(fut, 2 seconds)
res mustBe (14)
}
@Test
def `await in a nested if-else expression 4`() {
val o = new TestIfElse1Class
val fut = o.m4(10)
val res = Await.result(fut, 2 seconds)
res mustBe (14)
}
}
|
