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

Merge with upstream

Browse source
This commit is contained in:
Viktor Klang 2011-04-26 13:46:54 +02:00
commit 233310b807
1 changed files with 7 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

13
akka-actor-tests/src/test/scala/akka/dispatch/FutureSpec.scala
View file

@ -557,18 +557,19 @@ class FutureSpec extends JUnitSuite {
@Test def dataFlowAPIshouldbeSlick {
import Future.flow
val s1, s2 = new StandardLatch
def callService1 = Future { s1.awaitUninterruptible; 1 }
def callService2 = Future { s2.awaitUninterruptible; 9 }
val i1, i2, s1, s2 = new StandardLatch
val result = flow {
callService1() + callService2()
}
val callService1 = Future { i1.open; s1.awaitUninterruptible; 1 }
val callService2 = Future { i2.open; s2.awaitUninterruptible; 9 }
val result = flow { callService1() + callService2() }
assert(!s1.isOpen)
assert(!s2.isOpen)
assert(!result.isCompleted)
assert(i1.tryAwaitUninterruptible(2000, TimeUnit.MILLISECONDS))
assert(i2.tryAwaitUninterruptible(2000, TimeUnit.MILLISECONDS))
s1.open
s2.open
assert(result.get === 10)