Struct PersistentFSM 

pub struct PersistentFSM<S, D, C, E, Err>
where
    S: Clone + Send + 'static,
    D: Send + 'static,
    C: Send + 'static,
    E: Clone + Send + 'static,
    Err: Error + Send + 'static,
{ /* private fields */ }

Implementations

impl<S, D, C, E, Err> PersistentFSM<S, D, C, E, Err>

where S: Clone + PartialEq + Debug + Send + 'static, D: Send + 'static, C: Send + 'static, E: Clone + Send + 'static, Err: Error + Send + 'static,

pub fn new(persistence_id: impl Into<String>) -> Self

pub fn with_initial(self, s: S, d: D) -> Self

pub fn on_command<F>(self, f: F) -> Self

where F: FnMut(&S, &D, C) -> Result<Vec<E>, Err> + Send + 'static,

pub fn on_event<F>(self, f: F) -> Self

where F: FnMut(&mut S, &mut D, &E) + Send + 'static,

pub fn with_codec<EncF, DecF>(self, encode: EncF, decode: DecF) -> Self

where EncF: Fn(&E) -> Result<Vec<u8>, String> + Send + Sync + 'static, DecF: Fn(&[u8]) -> Result<E, String> + Send + Sync + 'static,

pub fn state(&self) -> Option<&S>

pub fn data(&self) -> Option<&D>

pub fn transitions(&self) -> &[(S, S)]

History of state transitions seen since boot. Useful for tests.

pub async fn recover<J: Journal>( &mut self, journal: Arc<J>, permitter: &RecoveryPermitter, ) -> Result<u64, EventsourcedError<Err>>

pub async fn handle<J: Journal>( &mut self, journal: Arc<J>, cmd: C, ) -> Result<(), EventsourcedError<Err>>