akka.testkit
Class TestLatch
java.lang.Object
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>
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TestLatch
public TestLatch(int count,
ActorSystem system)
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>