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

make timing requirements for lenient for ReliableProxySpec, see #2637

Browse source
This commit is contained in:
Roland 2012-11-05 13:33:14 +01:00
parent 8eec825f18
commit 29cf71d6bc
1 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

8
akka-contrib/src/multi-jvm/scala/akka/contrib/pattern/ReliableProxySpec.scala
View file

@ -122,8 +122,8 @@ class ReliableProxySpec extends MultiNodeSpec(ReliableProxySpec) with STMultiNod
enterBarrier("test2b")
runOn(local) {
testConductor.throttle(local, remote, Direction.Send, -1)
expectTransition(Active, Idle)
testConductor.throttle(local, remote, Direction.Send, -1).await
within(5 seconds) { expectTransition(Active, Idle) }
}
runOn(remote) {
within(1 second) {
@ -152,8 +152,8 @@ class ReliableProxySpec extends MultiNodeSpec(ReliableProxySpec) with STMultiNod
enterBarrier("test3a")
runOn(local) {
testConductor.throttle(local, remote, Direction.Receive, -1)
expectTransition(Active, Idle)
testConductor.throttle(local, remote, Direction.Receive, -1).await
within(5 seconds) { expectTransition(Active, Idle) }
}
enterBarrier("test3b")