"Live" version of allPersistenceIds

dnvriend / akka-persistence-inmemory

Akka-persistence-inmemory is a plugin for akka-persistence that stores journal and snapshot messages memory, which is very useful when testing persistent actors, persistent FSM and akka cluster

Apache License 2.0

134 stars 41 forks source link

"Live" version of allPersistenceIds #10

Closed eshepelyuk closed 9 years ago

eshepelyuk commented 9 years ago

Implementation of akka.persistence.query.scaladsl.AllPersistenceIdsQuery trait. Doesn't complete stream and keep publishing updates to query.

dnvriend commented 9 years ago

Thanks again for your contribution! This is great work! I have made some minor changes to InMemoryReadJournalTest (wait time set to 100.mills)