From d567a088499acfa0369b64509bc2919f585eaf8f Mon Sep 17 00:00:00 2001
From: Viktor Klang <viktor.klang@gmail.com>
Date: Tue, 26 Apr 2011 13:37:06 +0200
Subject: [PATCH] =?UTF-8?q?Added=20a=20test=20to=20validate=20the=20API,?=
 =?UTF-8?q?=20it=C2=B4s=20gorgeous?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../test/scala/akka/dispatch/FutureSpec.scala | 21 +++++++++++++++----
 1 file changed, 17 insertions(+), 4 deletions(-)

diff --git a/akka-actor-tests/src/test/scala/akka/dispatch/FutureSpec.scala b/akka-actor-tests/src/test/scala/akka/dispatch/FutureSpec.scala
index 3749cc4bbd..03232aac13 100644
--- a/akka-actor-tests/src/test/scala/akka/dispatch/FutureSpec.scala
+++ b/akka-actor-tests/src/test/scala/akka/dispatch/FutureSpec.scala
@@ -518,7 +518,7 @@ class FutureSpec extends JUnitSuite {
     two << 9
 
     assert(List(one, two).forall(_.isCompleted == true))
-    assert(simpleResult.await.result.get === 10)
+    assert(simpleResult.get === 10)
 
   }
 
@@ -542,17 +542,30 @@ class FutureSpec extends JUnitSuite {
     y1 << 1 // When this is set, it should cascade down the line
 
     assert(ly.tryAwaitUninterruptible(2000, TimeUnit.MILLISECONDS))
-    assert(x1.await.result.get === 1)
+    assert(x1.get === 1)
     assert(!lz.isOpen)
 
     y2 << 9 // When this is set, it should cascade down the line
 
     assert(lz.tryAwaitUninterruptible(2000, TimeUnit.MILLISECONDS))
-    assert(x2.await.result.get === 9)
+    assert(x2.get === 9)
 
     assert(List(x1,x2,y1,y2).forall(_.isCompleted == true))
 
-    assert(result.await.get === 10)
+    assert(result.get === 10)
+  }
+
+  @Test def dataFlowAPIshouldbeSlick {
+    import Future.flow
+
+    def callService1 = Future { 1 }
+    def callService2 = Future { 9 }
+
+    val result = flow {
+      callService1() + callService2()
+    }
+
+    assert(result.get === 10)
   }
 
   @Test def futureCompletingWithContinuationsFailure {