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

Minor corrections from review comments

Browse source
This commit is contained in:
Patrik Nordwall 2011-12-15 23:43:04 +01:00
parent da24cb03fd
commit ff35ae9e37
3 changed files with 10 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

12
akka-docs/scala/code/akka/docs/future/FutureDocSpec.scala
View file

@ -9,6 +9,7 @@ import akka.actor.Status.Failure
import akka.dispatch.Future
import akka.dispatch.Await
import akka.util.duration._
import akka.dispatch.Promise
object FutureDocSpec {
@ -95,9 +96,7 @@ class FutureDocSpec extends AkkaSpec {
val f1 = Future {
"Hello" + "World"
}
val f2 = Future {
3
}
val f2 = Promise.successful(3)
val f3 = f1 map { x ⇒
f2 map { y ⇒
x.length * y
@ -112,9 +111,7 @@ class FutureDocSpec extends AkkaSpec {
val f1 = Future {
"Hello" + "World"
}
val f2 = Future {
3
}
val f2 = Promise.successful(3)
val f3 = f1 flatMap { x ⇒
f2 map { y ⇒
x.length * y
@ -133,6 +130,9 @@ class FutureDocSpec extends AkkaSpec {
c ← Future(a - 1) // 5 - 1 = 4
} yield b * c // 6 * 4 = 24
// Note that the execution of futures a, b, and c
// are not done in parallel.
val result = Await.result(f, 1 second)
result must be(24)
//#for-comprehension