Package org.apache.pekko.testkit

Class TestBarrier

java.lang.Object

org.apache.pekko.testkit.TestBarrier

public class TestBarrier
extends Object

Constructor Summary

Constructors

Constructor	Description
TestBarrier(int count)

Method Summary

Modifier and Type	Method	Description
static TestBarrier	apply(int count)
void	await(ActorSystem system)
void	await(scala.concurrent.duration.FiniteDuration timeout, ActorSystem system)
static scala.concurrent.duration.FiniteDuration	DefaultTimeout()
void	reset()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

TestBarrier

public TestBarrier(int count)

Method Details

DefaultTimeout

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

apply

public static TestBarrier apply(int count)

await

public void await(ActorSystem system)

await

public void await(scala.concurrent.duration.FiniteDuration timeout,
 ActorSystem system)

reset

public void reset()