Package org.apache.pekko.persistence.testkit.scaladsl

Class PersistenceProbeBehavior$

java.lang.Object

org.apache.pekko.persistence.testkit.scaladsl.PersistenceProbeBehavior$

public class PersistenceProbeBehavior$
extends Object

Factory methods to create PersistenceProbeBehavior instances for testing.

Since:

1.3.0

Field Summary

Fields

Modifier and Type	Field	Description
static final PersistenceProbeBehavior$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
PersistenceProbeBehavior$()

Method Summary

Modifier and Type	Method	Description
<Command, State> PersistenceProbeBehavior.DurableState<Command,State>	fromDurableState(Behavior<Command> behavior, scala.Option<State> initialState)
<Command, State> scala.None$	fromDurableState$default$2()
<Command, Event, State> PersistenceProbeBehavior.EventSourced<Command,Event,State>	fromEventSourced(Behavior<Command> behavior, scala.Option<scala.Tuple2<State,Object>> initialStateAndSequenceNr)	Given an EventSourcedBehavior, produce a non-persistent Behavior which synchronously publishes events and snapshots for inspection.
<Command, Event, State> PersistenceProbeBehavior.EventSourced<Command,Event,State>	fromEventSourced(Behavior<Command> behavior, State initialState)
<Command, Event, State> scala.None$	fromEventSourced$default$2()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

MODULE$

public static final PersistenceProbeBehavior$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

PersistenceProbeBehavior$

public PersistenceProbeBehavior$()

Method Details

fromEventSourced

public <Command,
Event,
State>
PersistenceProbeBehavior.EventSourced<Command,Event,State> fromEventSourced(Behavior<Command> behavior,
 scala.Option<scala.Tuple2<State,Object>> initialStateAndSequenceNr)

Given an EventSourcedBehavior, produce a non-persistent Behavior which synchronously publishes events and snapshots for inspection. State is updated as in the EventSourcedBehavior, and side effects are performed synchronously. The resulting Behavior is, contingent on the command handling, event handling, and side effects being compatible with the BehaviorTestKit, testable with the BehaviorTestKit.

The returned Behavior does not intrinsically depend on configuration: it therefore does not serialize and assumes an unbounded stash for commands.

fromEventSourced

public <Command,
Event,
State>
PersistenceProbeBehavior.EventSourced<Command,Event,State> fromEventSourced(Behavior<Command> behavior,
 State initialState)

fromEventSourced$default$2

public <Command,
Event,
State> scala.None$ fromEventSourced$default$2()

fromDurableState

public <Command,
State>
PersistenceProbeBehavior.DurableState<Command,State> fromDurableState(Behavior<Command> behavior,
 scala.Option<State> initialState)

fromDurableState$default$2

public <Command,
State> scala.None$ fromDurableState$default$2()