akka.persistence.testkit.scaladsl
EventSourcedBehaviorTestKit
Companion object EventSourcedBehaviorTestKit
trait EventSourcedBehaviorTestKit[Command, Event, State] extends AnyRef
- Annotations
- @ApiMayChange() @DoNotInherit()
- Source
- EventSourcedBehaviorTestKit.scala
- Alphabetic
- By Inheritance
- EventSourcedBehaviorTestKit
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def clear(): Unit
Clears the in-memory journal and snapshot storage and restarts the behavior.
- abstract def getState(): State
Retrieve the current state of the Behavior.
- abstract def initialize(events: Event*): Unit
- abstract def initialize(state: State, events: Event*): Unit
Initializes behavior from provided state and/or events.
- abstract def persistenceTestKit: PersistenceTestKit
The underlying
PersistenceTestKit
for the in-memory journal.The underlying
PersistenceTestKit
for the in-memory journal. Can be useful for advanced testing scenarios, such as simulating failures or populating the journal with events that are used for replay. - abstract def restart(): RestartResult[State]
Restart the behavior, which will then recover from stored snapshot and events.
Restart the behavior, which will then recover from stored snapshot and events. Can be used for testing that the recovery is correct.
- abstract def runCommand[R](creator: (ActorRef[R]) => Command): CommandResultWithReply[Command, Event, State, R]
Run one command with a
replyTo: ActorRef[R]
through the behavior.Run one command with a
replyTo: ActorRef[R]
through the behavior. The returned result contains emitted events, the state after applying the events, and the reply. - abstract def runCommand(command: Command): CommandResult[Command, Event, State]
Run one command through the behavior.
Run one command through the behavior. The returned result contains emitted events and the state after applying the events.
- abstract def snapshotTestKit: Option[SnapshotTestKit]
The underlying
SnapshotTestKit
for snapshot storage.The underlying
SnapshotTestKit
for snapshot storage. Present only if snapshots are enabled. Can be useful for advanced testing scenarios, such as simulating failures or populating the storage with snapshots that are used for replay.
Concrete Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- def +(other: String): String
- Implicit
- This member is added by an implicit conversion from EventSourcedBehaviorTestKit[Command, Event, State] toany2stringadd[EventSourcedBehaviorTestKit[Command, Event, State]] performed by method any2stringadd in scala.Predef.
- Definition Classes
- any2stringadd
- def ->[B](y: B): (EventSourcedBehaviorTestKit[Command, Event, State], B)
- Implicit
- This member is added by an implicit conversion from EventSourcedBehaviorTestKit[Command, Event, State] toArrowAssoc[EventSourcedBehaviorTestKit[Command, Event, State]] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @inline()
- 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]) @HotSpotIntrinsicCandidate() @native()
- def ensuring(cond: (EventSourcedBehaviorTestKit[Command, Event, State]) => Boolean, msg: => Any): EventSourcedBehaviorTestKit[Command, Event, State]
- Implicit
- This member is added by an implicit conversion from EventSourcedBehaviorTestKit[Command, Event, State] toEnsuring[EventSourcedBehaviorTestKit[Command, Event, State]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
- def ensuring(cond: (EventSourcedBehaviorTestKit[Command, Event, State]) => Boolean): EventSourcedBehaviorTestKit[Command, Event, State]
- Implicit
- This member is added by an implicit conversion from EventSourcedBehaviorTestKit[Command, Event, State] toEnsuring[EventSourcedBehaviorTestKit[Command, Event, State]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
- def ensuring(cond: Boolean, msg: => Any): EventSourcedBehaviorTestKit[Command, Event, State]
- Implicit
- This member is added by an implicit conversion from EventSourcedBehaviorTestKit[Command, Event, State] toEnsuring[EventSourcedBehaviorTestKit[Command, Event, State]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
- def ensuring(cond: Boolean): EventSourcedBehaviorTestKit[Command, Event, State]
- Implicit
- This member is added by an implicit conversion from EventSourcedBehaviorTestKit[Command, Event, State] toEnsuring[EventSourcedBehaviorTestKit[Command, Event, State]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
- 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
- @HotSpotIntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @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
- @HotSpotIntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @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])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)
- def formatted(fmtstr: String): String
- Implicit
- This member is added by an implicit conversion from EventSourcedBehaviorTestKit[Command, Event, State] toStringFormat[EventSourcedBehaviorTestKit[Command, Event, State]] performed by method StringFormat in scala.Predef.
- Definition Classes
- StringFormat
- Annotations
- @deprecated @inline()
- Deprecated
(Since version 2.12.16) Use
formatString.format(value)
instead ofvalue.formatted(formatString)
, or use thef""
string interpolator. In Java 15 and later,formatted
resolves to the new method in String which has reversed parameters.
- def →[B](y: B): (EventSourcedBehaviorTestKit[Command, Event, State], B)
- Implicit
- This member is added by an implicit conversion from EventSourcedBehaviorTestKit[Command, Event, State] toArrowAssoc[EventSourcedBehaviorTestKit[Command, Event, State]] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @deprecated
- Deprecated
(Since version 2.13.0) Use
->
instead. If you still wish to display it as one character, consider using a font with programming ligatures such as Fira Code.