Value Members

1.  final def !=(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

2.  final def ##: Int

   Definition Classes

   AnyRef → Any

3.  final def ==(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

4.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

5.  def clone(): AnyRef

   Attributes

   protected[lang]

   Definition Classes

   AnyRef

   Annotations

   @throws(classOf[java.lang.CloneNotSupportedException]) @native()

6.  final def eq(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

7.  def equals(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef → Any

8.  def finalize(): Unit

   Attributes

   protected[lang]

   Definition Classes

   AnyRef

   Annotations

   @throws(classOf[java.lang.Throwable])

9.  final def getClass(): Class[_ <: AnyRef]

   Definition Classes

   AnyRef → Any

   Annotations

   @native()

10.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

11.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

12.  final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

13.  final def notify(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

14.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

15.  def run(projection: Projection[_], max: FiniteDuration, interval: FiniteDuration)(assertFunction: => Unit): Unit

    Run a Projection and assert its projected data using the passed assert function, the max duration of the test and the interval between each assertion.

    Run a Projection and assert its projected data using the passed assert function, the max duration of the test and the interval between each assertion.

    Projection is started and stopped by the TestKit. While the projection is running, the assert function will be called every interval until it completes without errors (no exceptions or assertion errors are thrown).

    If the assert function doesn't complete without error within the passed max duration the test will fail.

    Note: when testing a Projection with this method, the Restart Backoff is disabled. Any backoff configuration settings from .conf file or programmatically added will be overwritten.

    projection

    - the Projection to run

    max

    - FiniteDuration delimiting the max duration of the test

    interval

    - FiniteDuration defining the interval in each the assert function will be called

    assertFunction

    - a by-name code block that exercise the test assertions

16.  def run(projection: Projection[_], max: FiniteDuration)(assertFunction: => Unit): Unit

    Run a Projection and assert its projected data using the passed assert function and the max duration of the test.

    Run a Projection and assert its projected data using the passed assert function and the max duration of the test.

    Projection is started and stopped by the TestKit. While the projection is running, the assert function will be called every 100 milliseconds until it completes without errors (no exceptions or assertion errors are thrown).

    If the assert function doesn't complete without error within the passed max duration the test will fail.

    Note: when testing a Projection with this method, the Restart Backoff is disabled. Any backoff configuration settings from .conf file or programmatically added will be overwritten.

    projection

    - the Projection to run

    max

    - FiniteDuration delimiting the max duration of the test

    assertFunction

    - a by-name code block that exercise the test assertions

17.  def run(projection: Projection[_])(assertFunction: => Unit): Unit

    Run a Projection and assert its projected data using the passed assert function.

    Run a Projection and assert its projected data using the passed assert function.

    Projection is started and stopped by the TestKit. While the projection is running, the assert function will be called every 100 milliseconds until it completes without errors (no exceptions or assertion errors are thrown).

    If the assert function doesn't complete without error within the configuration provided to pekko.actor.testkit.typed.single-expect-default (3 seconds by default with no dilation) then the test will fail.

    Note: when testing a Projection with this method, the Restart Backoff is disabled. Any backoff configuration settings from .conf file or programmatically added will be overwritten.

    projection

    - the Projection to run

    assertFunction

    - a by-name code block that exercise the test assertions

18.  def runWithTestSink(projection: Projection[_])(assertFunction: (Probe[Done]) => Unit): Unit

    Run a Projection with an attached TestSubscriber.Probe allowing control over the pace in which the elements flow through the Projection.

    Run a Projection with an attached TestSubscriber.Probe allowing control over the pace in which the elements flow through the Projection.

    The assertion function receives a TestSubscriber.Probe that you can use to request elements.

    The Projection starts as soon as the first element is requested by the TestSubscriber.Probe, new elements will be emitted as requested. The Projection is stopped once the assert function completes.

    projection

    - the Projection to run

    assertFunction

    - a function receiving a TestSubscriber.Probe[Done]

19.  final def synchronized[T0](arg0: => T0): T0

    Definition Classes

    AnyRef

20.  def toString(): String

    Definition Classes

    AnyRef → Any

21.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.InterruptedException])

22.  final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.InterruptedException])

23.  final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.InterruptedException]) @native()