Rename AllPersistenceIdsQuery -> PersistenceIdsQuery in docs (#24121)
* AllPersistenceIdsQuery -> PersistenceIdsQuery * Replaced additional instances of old name allPersistenceIDs with new persistenceIDs in docs and comments
This commit is contained in:
parent
af8a81f45f
commit
ad57120ec2
6 changed files with 10 additions and 10 deletions
|
|
@ -12,7 +12,7 @@ import akka.stream.javadsl.Source
|
|||
trait CurrentPersistenceIdsQuery extends ReadJournal {
|
||||
|
||||
/**
|
||||
* Same type of query as [[PersistenceIdsQuery#allPersistenceIds]] but the stream
|
||||
* Same type of query as [[PersistenceIdsQuery#persistenceIds]] but the stream
|
||||
* is completed immediately when it reaches the end of the "result set". Persistent
|
||||
* actors that are created after the query is completed are not included in the stream.
|
||||
*/
|
||||
|
|
|
|||
|
|
@ -31,7 +31,7 @@ class LeveldbReadJournal(scaladslReadJournal: akka.persistence.query.journal.lev
|
|||
with EventsByTagQuery with CurrentEventsByTagQuery {
|
||||
|
||||
/**
|
||||
* `allPersistenceIds` is used for retrieving all `persistenceIds` of all
|
||||
* `persistenceIds` is used for retrieving all `persistenceIds` of all
|
||||
* persistent actors.
|
||||
*
|
||||
* The returned event stream is unordered and you can expect different order for multiple
|
||||
|
|
@ -52,7 +52,7 @@ class LeveldbReadJournal(scaladslReadJournal: akka.persistence.query.journal.lev
|
|||
scaladslReadJournal.persistenceIds().asJava
|
||||
|
||||
/**
|
||||
* Same type of query as [[#allPersistenceIds]] but the stream
|
||||
* Same type of query as [[#persistenceIds]] but the stream
|
||||
* is completed immediately when it reaches the end of the "result set". Persistent
|
||||
* actors that are created after the query is completed are not included in the stream.
|
||||
*/
|
||||
|
|
|
|||
|
|
@ -41,7 +41,7 @@ class LeveldbReadJournal(system: ExtendedActorSystem, config: Config) extends Re
|
|||
private val maxBufSize: Int = config.getInt("max-buffer-size")
|
||||
|
||||
/**
|
||||
* `allPersistenceIds` is used for retrieving all `persistenceIds` of all
|
||||
* `persistenceIds` is used for retrieving all `persistenceIds` of all
|
||||
* persistent actors.
|
||||
*
|
||||
* The returned event stream is unordered and you can expect different order for multiple
|
||||
|
|
@ -66,7 +66,7 @@ class LeveldbReadJournal(system: ExtendedActorSystem, config: Config) extends Re
|
|||
}
|
||||
|
||||
/**
|
||||
* Same type of query as [[#allPersistenceIds]] but the stream
|
||||
* Same type of query as [[#persistenceIds]] but the stream
|
||||
* is completed immediately when it reaches the end of the "result set". Persistent
|
||||
* actors that are created after the query is completed are not included in the stream.
|
||||
*/
|
||||
|
|
|
|||
|
|
@ -12,7 +12,7 @@ import akka.stream.scaladsl.Source
|
|||
trait CurrentPersistenceIdsQuery extends ReadJournal {
|
||||
|
||||
/**
|
||||
* Same type of query as [[PersistenceIdsQuery#allPersistenceIds]] but the stream
|
||||
* Same type of query as [[PersistenceIdsQuery#persistenceIds]] but the stream
|
||||
* is completed immediately when it reaches the end of the "result set". Persistent
|
||||
* actors that are created after the query is completed are not included in the stream.
|
||||
*/
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue