Package akka.persistence.typed.internal
Class StashState
- java.lang.Object
-
- akka.persistence.typed.internal.StashState
-
public class StashState extends java.lang.Object
INTERNAL API: stash buffer state in order to survive restart of internal behavior
-
-
Constructor Summary
Constructors Constructor Description StashState(EventSourcedSettings settings)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
clearStashBuffers()
void
decrementUnstashAllProgress()
StashBuffer<InternalProtocol>
internalStashBuffer()
boolean
isUnstashAllInProgress()
void
startUnstashAll()
StashBuffer<InternalProtocol>
userStashBuffer()
-
-
-
Constructor Detail
-
StashState
public StashState(EventSourcedSettings settings)
-
-
Method Detail
-
clearStashBuffers
public void clearStashBuffers()
-
decrementUnstashAllProgress
public void decrementUnstashAllProgress()
-
internalStashBuffer
public StashBuffer<InternalProtocol> internalStashBuffer()
-
isUnstashAllInProgress
public boolean isUnstashAllInProgress()
-
startUnstashAll
public void startUnstashAll()
-
userStashBuffer
public StashBuffer<InternalProtocol> userStashBuffer()
-
-