1 files changed, 46 insertions, 0 deletions
diff --git a/src/test/scala/scala/async/run/block1/block1.scala b/src/test/scala/scala/async/run/block1/block1.scala
new file mode 100644
index 0000000..29890bb
--- /dev/null
+++ b/src/test/scala/scala/async/run/block1/block1.scala
@@ -0,0 +1,46 @@
+/**
+ * Copyright (C) 2012 Typesafe Inc. <http://www.typesafe.com>
+ */
+
+package scala.async
+package run
+package block1
+
+import language.{reflectiveCalls, postfixOps}
+import scala.concurrent.{Future, ExecutionContext, future, Await}
+import scala.concurrent.duration._
+import scala.async.Async.{async, await}
+import org.junit.Test
+import org.junit.runner.RunWith
+import org.junit.runners.JUnit4
+
+
+class Test1Class {
+
+  import ExecutionContext.Implicits.global
+
+  def m1(x: Int): Future[Int] = future {
+    Thread.sleep(1000)
+    x + 2
+  }
+
+  def m4(y: Int): Future[Int] = async {
+    val f1 = m1(y)
+    val f2 = m1(y + 2)
+    val x1 = await(f1)
+    println("between two awaits")
+    val x2 = await(f2)
+    x1 + x2
+  }
+}
+
+@RunWith(classOf[JUnit4])
+class Block1Spec extends MinimalScalaTest {
+
+  @Test def `support a simple await` {
+    val o = new Test1Class
+    val fut = o.m4(10)
+    val res = Await.result(fut, 2 seconds)
+    res mustBe (26)
+  }
+}