Package akka.testkit

Class 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 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$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