Packages

object TestProjection

Annotations
@ApiMayChange()
Source
TestProjection.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. TestProjection
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def create[Offset, Envelope](projectionId: ProjectionId, sourceProvider: SourceProvider[Offset, Envelope], handler: Supplier[Handler[Envelope]]): TestProjection[Offset, Envelope]

    Create a TestProjection that can be used to assert a pekko.projection.javadsl.Handler implementation.

    Create a TestProjection that can be used to assert a pekko.projection.javadsl.Handler implementation.

    The TestProjection allows the user to test their pekko.projection.javadsl.Handler implementation in isolation, without requiring the Projection implementation (i.e. a database) to exist at test runtime.

    The pekko.projection.javadsl.SourceProvider can be a concrete implementation, or a TestSourceProvider to provide further test isolation.

    The TestProjection uses an at-least-once offset saving strategy where an offset is saved for each element.

    The TestProjection does not support grouping, at least once offset batching, or restart backoff strategies.

    projectionId

    - a Projection ID

    sourceProvider

    - a pekko.projection.javadsl.SourceProvider to supply envelopes to the Projection

    handler

    - a user-defined pekko.projection.javadsl.Handler to run within the Projection