raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Value not def for underlying state store (#30748)

Browse source 
* Value not def for underlying state store

* Ooops forgot to remove parens

* Remove type param

* Other type

* Fix types

* Similar reference wrapper issue

* Trailing spaces removed
This commit is contained in:
Justin Pihony 2021-10-06 12:20:48 -04:00 • committed by GitHub
parent e0ce825a55
commit 1e05c52c5d
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 8 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

7
akka-persistence-testkit/src/main/scala/akka/persistence/testkit/query/PersistenceTestKitReadJournalProvider.scala
View file

@ -9,10 +9,11 @@ import com.typesafe.config.Config
class PersistenceTestKitReadJournalProvider(system: ExtendedActorSystem, config: Config, configPath: String)
extends ReadJournalProvider {
override def scaladslReadJournal(): scaladsl.PersistenceTestKitReadJournal =
private val _scaladslReadJournal =
new scaladsl.PersistenceTestKitReadJournal(system, config, configPath)
override def scaladslReadJournal(): scaladsl.PersistenceTestKitReadJournal =
_scaladslReadJournal
override def javadslReadJournal(): javadsl.PersistenceTestKitReadJournal =
new javadsl.PersistenceTestKitReadJournal(scaladslReadJournal())
new javadsl.PersistenceTestKitReadJournal(_scaladslReadJournal)
}

7
akka-persistence-testkit/src/main/scala/akka/persistence/testkit/state/PersistenceTestKitDurableStateStoreProvider.scala
View file

@ -14,9 +14,10 @@ import akka.persistence.testkit.state.javadsl.{
}
class PersistenceTestKitDurableStateStoreProvider(system: ExtendedActorSystem) extends DurableStateStoreProvider {
private def _scaladslDurableStateStore[T]() = new PersistenceTestKitDurableStateStore[T](system)
override def scaladslDurableStateStore(): DurableStateStore[Any] = _scaladslDurableStateStore[Any]()
private val _scaladslDurableStateStore = new PersistenceTestKitDurableStateStore[Any](system)
override def scaladslDurableStateStore(): DurableStateStore[Any] = _scaladslDurableStateStore
override def javadslDurableStateStore(): JDurableStateStore[AnyRef] =
new JPersistenceTestKitDurableStateStore[AnyRef](_scaladslDurableStateStore())
new JPersistenceTestKitDurableStateStore[AnyRef](
_scaladslDurableStateStore.asInstanceOf[PersistenceTestKitDurableStateStore[AnyRef]])
}