The change here principally fixes a bug with the new offset store where we weren't recovering the last offset. 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 recovered, nor any entity manager for that matter. Consequently, a new on_initial_recovery_completed method has been added to the entity behaviour trait, and called by the entity manager.
The change here principally fixes a bug with the new offset store where we weren't recovering the last offset. 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 recovered, nor any entity manager for that matter. Consequently, a new
on_initial_recovery_completedmethod has been added to the entity behaviour trait, and called by the entity manager.Fixes #https://github.com/lightbend/akka-edge-rs/issues/86