final class ProjectionTestKit extends AnyRef
- Source
- ProjectionTestKit.scala
- Alphabetic
- By Inheritance
- ProjectionTestKit
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def run(projection: Projection[_], max: Duration, interval: Duration, assertFunction: Effect): 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
intervaluntil it completes without errors (no exceptions or assertion errors are thrown).If the assert function doesn't complete without error within the passed
maxduration the test will fail.Note: when testing a Projection with this method, the Restart Backoff is disabled. Any backoff configuration settings from
.conffile or programmatically added will be overwritten.- projection
- the Projection to run
- max
- Duration delimiting the max duration of the test
- interval
- Duration defining the interval in each the assert function will be called
- assertFunction
- a function that exercises the test assertions
- def run(projection: Projection[_], max: Duration, assertFunction: Effect): 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
maxduration the test will fail.Note: when testing a Projection with this method, the Restart Backoff is disabled. Any backoff configuration settings from
.conffile or programmatically added will be overwritten.- projection
- the Projection to run
- max
- Duration delimiting the max duration of the test
- assertFunction
- a function that exercises the test assertions
- def run(projection: Projection[_], assertFunction: Effect): 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 3 seconds the test will fail.
Note: when testing a Projection with this method, the Restart Backoff is disabled. Any backoff configuration settings from
.conffile or programmatically added will be overwritten.- projection
- the Projection to run
- assertFunction
- a function that exercises the test assertions
- def runWithTestSink(projection: Projection[_], assertFunction: Procedure[Probe[Done]]): Unit
Run a Projection with an attached
TestSubscriber.Probeallowing control over the pace in which the elements flow through the Projection.Run a Projection with an attached
TestSubscriber.Probeallowing control over the pace in which the elements flow through the Projection.The assertion function receives a
TestSubscriber.Probethat 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]
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])