diff --git a/core/src/main/scala/akka/persistence/r2dbc/R2dbcSettings.scala b/core/src/main/scala/akka/persistence/r2dbc/R2dbcSettings.scala index bc32c1fe..249a3b37 100644 --- a/core/src/main/scala/akka/persistence/r2dbc/R2dbcSettings.scala +++ b/core/src/main/scala/akka/persistence/r2dbc/R2dbcSettings.scala @@ -257,7 +257,7 @@ final class R2dbcSettings private ( /** * INTERNAL API: All journal tables and their the lower slice */ - @InternalApi private[akka] val alljournalTablesWithSchema: Map[String, Int] = { + @InternalApi private[akka] val allJournalTablesWithSchema: Map[String, Int] = { (0 until NumberOfSlices).foldLeft(Map.empty[String, Int]) { case (acc, slice) => val table = journalTableWithSchema(slice) if (acc.contains(table)) acc diff --git a/core/src/test/scala/akka/persistence/r2dbc/TestDbLifecycle.scala b/core/src/test/scala/akka/persistence/r2dbc/TestDbLifecycle.scala index 936b1ba4..429e1680 100644 --- a/core/src/test/scala/akka/persistence/r2dbc/TestDbLifecycle.scala +++ b/core/src/test/scala/akka/persistence/r2dbc/TestDbLifecycle.scala @@ -51,7 +51,7 @@ trait TestDbLifecycle extends BeforeAndAfterAll { this: Suite => override protected def beforeAll(): Unit = { try { - r2dbcSettings.alljournalTablesWithSchema.foreach { case (table, minSlice) => + r2dbcSettings.allJournalTablesWithSchema.foreach { case (table, minSlice) => Await.result( r2dbcExecutor(minSlice).updateOne("beforeAll delete")(_.createStatement(s"delete from $table")), 10.seconds) diff --git a/core/src/test/scala/akka/persistence/r2dbc/journal/PersistTagsSpec.scala b/core/src/test/scala/akka/persistence/r2dbc/journal/PersistTagsSpec.scala index 02c395c4..5351a7d3 100644 --- a/core/src/test/scala/akka/persistence/r2dbc/journal/PersistTagsSpec.scala +++ b/core/src/test/scala/akka/persistence/r2dbc/journal/PersistTagsSpec.scala @@ -44,7 +44,7 @@ class PersistTagsSpec } private def selectAllRows(): IndexedSeq[Row] = - r2dbcSettings.alljournalTablesWithSchema.toVector.sortBy(_._1).flatMap { case (table, minSlice) => + r2dbcSettings.allJournalTablesWithSchema.toVector.sortBy(_._1).flatMap { case (table, minSlice) => selectRows(table, minSlice) } diff --git a/core/src/test/scala/akka/persistence/r2dbc/journal/PersistTimestampSpec.scala b/core/src/test/scala/akka/persistence/r2dbc/journal/PersistTimestampSpec.scala index 397cc854..bacf5cf5 100644 --- a/core/src/test/scala/akka/persistence/r2dbc/journal/PersistTimestampSpec.scala +++ b/core/src/test/scala/akka/persistence/r2dbc/journal/PersistTimestampSpec.scala @@ -64,7 +64,7 @@ class PersistTimestampSpec } private def selectAllRows(): IndexedSeq[Row] = - r2dbcSettings.alljournalTablesWithSchema.toVector.sortBy(_._1).flatMap { case (table, minSlice) => + r2dbcSettings.allJournalTablesWithSchema.toVector.sortBy(_._1).flatMap { case (table, minSlice) => selectRows(table, minSlice) }