From 1e05c52c5dcf57ef17d988c700e4ed7302311037 Mon Sep 17 00:00:00 2001 From: Justin Pihony Date: Wed, 6 Oct 2021 12:20:48 -0400 Subject: [PATCH] Value not def for underlying state store (#30748) * 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 --- .../query/PersistenceTestKitReadJournalProvider.scala | 7 ++++--- .../PersistenceTestKitDurableStateStoreProvider.scala | 7 ++++--- 2 files changed, 8 insertions(+), 6 deletions(-) diff --git a/akka-persistence-testkit/src/main/scala/akka/persistence/testkit/query/PersistenceTestKitReadJournalProvider.scala b/akka-persistence-testkit/src/main/scala/akka/persistence/testkit/query/PersistenceTestKitReadJournalProvider.scala index 5a1c1a18c3..55c8d954db 100644 --- a/akka-persistence-testkit/src/main/scala/akka/persistence/testkit/query/PersistenceTestKitReadJournalProvider.scala +++ b/akka-persistence-testkit/src/main/scala/akka/persistence/testkit/query/PersistenceTestKitReadJournalProvider.scala @@ -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) } diff --git a/akka-persistence-testkit/src/main/scala/akka/persistence/testkit/state/PersistenceTestKitDurableStateStoreProvider.scala b/akka-persistence-testkit/src/main/scala/akka/persistence/testkit/state/PersistenceTestKitDurableStateStoreProvider.scala index 38d53818df..8270a193ed 100644 --- a/akka-persistence-testkit/src/main/scala/akka/persistence/testkit/state/PersistenceTestKitDurableStateStoreProvider.scala +++ b/akka-persistence-testkit/src/main/scala/akka/persistence/testkit/state/PersistenceTestKitDurableStateStoreProvider.scala @@ -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]]) }