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