Package org.apache.pekko.persistence.testkit.internal

Class PersistenceProbeImpl$

java.lang.Object

org.apache.pekko.persistence.testkit.internal.PersistenceProbeImpl$

public class PersistenceProbeImpl$
extends Object

INTERNAL API

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
PersistenceProbeImpl$()

Method Summary

Modifier and Type	Method	Description
<Command, State> Behavior<Command>	durableState(Behavior<Command> behavior, scala.Option<State> fromState, scala.Function3<State,Object,String,scala.runtime.BoxedUnit> onPersist)
<Command, Event, State> Behavior<Command>	eventSourced(Behavior<Command> behavior, scala.Option<scala.Tuple2<State,Object>> fromStateAndSequenceNr, scala.Function3<Event,Object,scala.collection.immutable.Set<String>,scala.runtime.BoxedUnit> onEvent, scala.Function2<State,Object,scala.runtime.BoxedUnit> onSnapshot)

Methods inherited from class java.lang.Object

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

Field Details

MODULE$

public static final PersistenceProbeImpl$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

PersistenceProbeImpl$

public PersistenceProbeImpl$()

Method Details

eventSourced

public <Command,
Event,
State> Behavior<Command> eventSourced(Behavior<Command> behavior,
 scala.Option<scala.Tuple2<State,Object>> fromStateAndSequenceNr,
 scala.Function3<Event,Object,scala.collection.immutable.Set<String>,scala.runtime.BoxedUnit> onEvent,
 scala.Function2<State,Object,scala.runtime.BoxedUnit> onSnapshot)

durableState

public <Command,
State> Behavior<Command> durableState(Behavior<Command> behavior,
 scala.Option<State> fromState,
 scala.Function3<State,Object,String,scala.runtime.BoxedUnit> onPersist)