public class TestLatch
extends java.lang.Object
implements scala.concurrent.Awaitable<scala.runtime.BoxedUnit>
Constructor and Description |
---|
TestLatch(int count,
ActorSystem system) |
Modifier and Type | Method and Description |
---|---|
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) |
public TestLatch(int count, ActorSystem system)
public static scala.concurrent.duration.FiniteDuration DefaultTimeout()
public static TestLatch apply(int count, ActorSystem system)
public void countDown()
public boolean isOpen()
public void open()
public void reset()
public TestLatch ready(scala.concurrent.duration.Duration atMost, scala.concurrent.CanAwait permit) throws java.util.concurrent.TimeoutException
ready
in interface scala.concurrent.Awaitable<scala.runtime.BoxedUnit>
java.util.concurrent.TimeoutException
public void result(scala.concurrent.duration.Duration atMost, scala.concurrent.CanAwait permit) throws java.lang.Exception
result
in interface scala.concurrent.Awaitable<scala.runtime.BoxedUnit>
java.lang.Exception