typo

akka · Feb 2, 2024 · c7dd202 · c7dd202
1 parent e8c1789
commit c7dd202
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git 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
@@ -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
@@ -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
@@ -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)
     }