Package akka.persistence.typed.internal

Class ReplayingEvents$

java.lang.Object

akka.persistence.typed.internal.ReplayingEvents$

public class ReplayingEvents$
extends java.lang.Object

INTERNAL API

Third (of four) behavior of an EventSourcedBehavior.

In this behavior we finally start replaying events, beginning from the last applied sequence number (i.e. the one up-until-which the snapshot recovery has brought us).

Once recovery is completed, the actor becomes Running, stashed messages are flushed and control is given to the user's handlers to drive the actors behavior from there.

See next behavior Running. See previous behavior ReplayingSnapshot.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
ReplayingEvents$()

Method Summary

Modifier and Type	Method	Description
<C,E,S> Behavior<InternalProtocol>	apply(BehaviorSetup<C,E,S> setup, ReplayingEvents.ReplayingState<S> state)

Methods inherited from class java.lang.Object

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

Field Detail

MODULE$

public static final ReplayingEvents$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

ReplayingEvents$

public ReplayingEvents$()

Method Detail

apply

public <C,E,S> Behavior<InternalProtocol> apply(BehaviorSetup<C,E,S> setup,
                                                            ReplayingEvents.ReplayingState<S> state)