We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 2565190 commit c86d77cCopy full SHA for c86d77c
actor.go
@@ -152,9 +152,11 @@ func (entity *actor[T]) recoverFromSnapshot(ctx context.Context) error {
152
// we do have the latest state just recover from it
153
if event != nil {
154
// set the current state
155
- if err := event.GetResultingState().UnmarshalTo(entity.currentState); err != nil {
+ currentState := entity.InitialState()
156
+ if err := event.GetResultingState().UnmarshalTo(currentState); err != nil {
157
return errors.Wrap(err, "failed unmarshal the latest state")
158
}
159
+ entity.currentState = currentState
160
161
// set the event counter
162
entity.eventsCounter.Store(event.GetSequenceNumber())
0 commit comments