Tags: akka/akka-edge-rs
Tags
More effect combinators (#99) * Recovery the last offset fix The change here principally fixes a bug where we weren't recovering the last offset of the offset store correctly. However, I then found a race condition where the consumer projection wasn't waiting for the offset store to finish its recovery. Further, the offset store had no means to convey that it had fully recovery, nor any entity manager for that matter. Consequently, a new `on_initial_recovery_completed` method has been added to the entity behaviour trait. * More effect combinators Effect combinators added for emitting events and replying; both with the same abilities as `and_then` to inspect behaviour and state, and act in accordance with the previous result.
PreviousNext