trait TestProjection[Offset, Envelope] extends Projection[Envelope]
- Source
 - TestProjection.scala
 
Linear Supertypes
Ordering
- Alphabetic
 - By Inheritance
 
Inherited
- TestProjection
 - Projection
 - AnyRef
 - Any
 
- Hide All
 - Show All
 
Visibility
- Public
 - Protected
 
Abstract Value Members
-   abstract  def projectionId: ProjectionId
- Definition Classes
 - Projection
 
 -   abstract  def statusObserver: StatusObserver[Envelope]
- Definition Classes
 - Projection
 
 -   abstract  def withOffsetStoreFactory(factory: () => TestOffsetStore[Offset]): TestProjection[Offset, Envelope]
The offset store factory.
The offset store factory. The offset store has the same lifetime as the Projection. It is instantiated when the projection is first run and is created with newState.
 -   abstract  def withRestartBackoff(minBackoff: Duration, maxBackoff: Duration, randomFactor: Double, maxRestarts: Int): Projection[Envelope]
Java API
Java API
- Definition Classes
 - Projection
 
 -   abstract  def withRestartBackoff(minBackoff: Duration, maxBackoff: Duration, randomFactor: Double): Projection[Envelope]
Java API
Java API
- Definition Classes
 - Projection
 
 -   abstract  def withRestartBackoff(minBackoff: FiniteDuration, maxBackoff: FiniteDuration, randomFactor: Double, maxRestarts: Int): Projection[Envelope]
- Definition Classes
 - Projection
 
 -   abstract  def withRestartBackoff(minBackoff: FiniteDuration, maxBackoff: FiniteDuration, randomFactor: Double): Projection[Envelope]
- Definition Classes
 - Projection
 
 -   abstract  def withStartOffset(offset: Offset): TestProjection[Offset, Envelope]
The initial offset of the offset store.
 -   abstract  def withStatusObserver(observer: StatusObserver[Envelope]): TestProjection[Offset, Envelope]
- Definition Classes
 - TestProjection → Projection
 
 
Concrete 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()
 
 -   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])