Package org.apache.pekko.testkit

Class TestLatch

java.lang.Object

org.apache.pekko.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

Constructors

Constructor	Description
TestLatch(int count, ActorSystem system)

Method Summary

Modifier and Type	Method	Description
static int	$lessinit$greater$default$1()
static TestLatch	apply(int count, ActorSystem system)
static int	apply$default$1()
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

$lessinit$greater$default$1

public static int $lessinit$greater$default$1()

DefaultTimeout

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

apply

public static TestLatch apply(int count,
                              ActorSystem system)

apply$default$1

public static int apply$default$1()

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)
                throws java.util.concurrent.TimeoutException

Specified by:

ready in interface scala.concurrent.Awaitable<scala.runtime.BoxedUnit>

Throws:

java.util.concurrent.TimeoutException

result

public void result(scala.concurrent.duration.Duration atMost,
                   scala.concurrent.CanAwait permit)
            throws java.lang.Exception

Specified by:

result in interface scala.concurrent.Awaitable<scala.runtime.BoxedUnit>

Throws:

java.lang.Exception