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 Object implements scala.concurrent.Awaitable<scala.runtime.BoxedUnit>

  • Constructor Details

    • TestLatch

      public TestLatch(int count, ActorSystem system)

  • Method Details

    • $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 TimeoutException
      Specified by:
      ready in interface scala.concurrent.Awaitable<scala.runtime.BoxedUnit>
      Throws:
      TimeoutException

    • result

      public void result(scala.concurrent.duration.Duration atMost, scala.concurrent.CanAwait permit) throws Exception
      Specified by:
      result in interface scala.concurrent.Awaitable<scala.runtime.BoxedUnit>
      Throws:
      Exception