Package akka.persistence.query.scaladsl
Interface PersistenceIdsQuery
-
- All Superinterfaces:
ReadJournal
- All Known Implementing Classes:
LeveldbReadJournal
public interface PersistenceIdsQuery extends ReadJournal
A plugin may optionally support this query by implementing this trait.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Source<java.lang.String,NotUsed>
persistenceIds()
Query allPersistentActor
identifiers, i.e.
-
-
-
Method Detail
-
persistenceIds
Source<java.lang.String,NotUsed> persistenceIds()
Query allPersistentActor
identifiers, i.e. as defined by thepersistenceId
of thePersistentActor
.The stream is not completed when it reaches the end of the currently used
persistenceIds
, but it continues to push newpersistenceIds
when new persistent actors are created. Corresponding query that is completed when it reaches the end of the currently currently usedpersistenceIds
is provided byCurrentPersistenceIdsQuery.currentPersistenceIds()
.
-
-