akka.testkit
Class TestLatch

java.lang.Object
  extended by akka.testkit.TestLatch
All Implemented Interfaces:
scala.concurrent.Awaitable<scala.runtime.BoxedUnit>

public class TestLatch
extends java.lang.Object
implements scala.concurrent.Awaitable<scala.runtime.BoxedUnit>


Constructor Summary
TestLatch(int count, ActorSystem system)
           
 
Method Summary
static TestLatch apply(int count, ActorSystem system)
           
 void countDown()
           
static scala.concurrent.duration.FiniteDuration DefaultTimeout()
           
 boolean isOpen()
           
 void open()
           
 TestLatch ready(scala.concurrent.duration.Duration atMost, scala.concurrent.CanAwait permit)
           
 void reset()
           
 void result(scala.concurrent.duration.Duration atMost, scala.concurrent.CanAwait permit)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TestLatch

public TestLatch(int count,
                 ActorSystem system)
Method Detail

DefaultTimeout

public static scala.concurrent.duration.FiniteDuration DefaultTimeout()

apply

public static TestLatch apply(int count,
                              ActorSystem system)

countDown

public void countDown()

isOpen

public boolean isOpen()

open

public void open()

reset

public void reset()

ready

public TestLatch ready(scala.concurrent.duration.Duration atMost,
                       scala.concurrent.CanAwait permit)
Specified by:
ready in interface scala.concurrent.Awaitable<scala.runtime.BoxedUnit>

result

public void result(scala.concurrent.duration.Duration atMost,
                   scala.concurrent.CanAwait permit)
Specified by:
result in interface scala.concurrent.Awaitable<scala.runtime.BoxedUnit>