This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko.git
The following commit(s) were added to refs/heads/main by this push:
new 3e5209a372 remove stray ) in test pids (#2739)
3e5209a372 is described below
commit 3e5209a37266a26d9d844472ab3d82115b9c88c7
Author: PJ Fanning <[email protected]>
AuthorDate: Mon Mar 16 16:34:19 2026 +0100
remove stray ) in test pids (#2739)
---
docs/src/test/scala/docs/stream/IntegrationDocSpec.scala | 2 +-
.../typed/scaladsl/EventSourcedBehaviorInterceptorSpec.scala | 2 +-
.../typed/scaladsl/EventSourcedBehaviorRecoveryTimeoutSpec.scala | 2 +-
.../persistence/typed/scaladsl/EventSourcedBehaviorReplySpec.scala | 2 +-
.../persistence/typed/scaladsl/EventSourcedBehaviorRetentionSpec.scala | 2 +-
.../pekko/persistence/typed/scaladsl/EventSourcedBehaviorSpec.scala | 2 +-
.../persistence/typed/scaladsl/EventSourcedBehaviorStashSpec.scala | 2 +-
.../persistence/typed/scaladsl/EventSourcedBehaviorTimersSpec.scala | 2 +-
.../pekko/persistence/typed/scaladsl/EventSourcedEventAdapterSpec.scala | 2 +-
.../persistence/typed/scaladsl/EventSourcedSnapshotAdapterSpec.scala | 2 +-
.../org/apache/pekko/persistence/typed/scaladsl/LoggerSourceSpec.scala | 2 +-
.../pekko/persistence/typed/scaladsl/SnapshotMutableStateSpec.scala | 2 +-
.../typed/state/scaladsl/DurableStateBehaviorInterceptorSpec.scala | 2 +-
.../typed/state/scaladsl/DurableStateBehaviorReplySpec.scala | 2 +-
.../typed/state/scaladsl/DurableStateBehaviorTimersSpec.scala | 2 +-
.../persistence/typed/delivery/EventSourcedProducerQueueSpec.scala | 2 +-
.../pekko/persistence/typed/scaladsl/SnapshotIsOptionalSpec.scala | 2 +-
17 files changed, 17 insertions(+), 17 deletions(-)
diff --git a/docs/src/test/scala/docs/stream/IntegrationDocSpec.scala
b/docs/src/test/scala/docs/stream/IntegrationDocSpec.scala
index 95b5a201f0..02df48ced3 100644
--- a/docs/src/test/scala/docs/stream/IntegrationDocSpec.scala
+++ b/docs/src/test/scala/docs/stream/IntegrationDocSpec.scala
@@ -115,7 +115,7 @@ object IntegrationDocSpec {
private val runningCount = new AtomicInteger
def convert(s: String): Future[String] = {
- println(s"running: $s (${runningCount.incrementAndGet()})")
+ println(s"running: $s (${runningCount.incrementAndGet()}")
Future {
if (s.nonEmpty && s.head.isLower)
Thread.sleep(500)
diff --git
a/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorInterceptorSpec.scala
b/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorInterceptorSpec.scala
index ce996c1a07..e52466b750 100644
---
a/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorInterceptorSpec.scala
+++
b/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorInterceptorSpec.scala
@@ -63,7 +63,7 @@ class EventSourcedBehaviorInterceptorSpec
import EventSourcedBehaviorInterceptorSpec._
val pidCounter = new AtomicInteger(0)
- private def nextPid(): PersistenceId =
PersistenceId.ofUniqueId(s"c${pidCounter.incrementAndGet()})")
+ private def nextPid(): PersistenceId =
PersistenceId.ofUniqueId(s"c${pidCounter.incrementAndGet()}")
"EventSourcedBehavior interceptor" must {
diff --git
a/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorRecoveryTimeoutSpec.scala
b/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorRecoveryTimeoutSpec.scala
index a5429116a2..c08b0e6539 100644
---
a/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorRecoveryTimeoutSpec.scala
+++
b/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorRecoveryTimeoutSpec.scala
@@ -69,7 +69,7 @@ class EventSourcedBehaviorRecoveryTimeoutSpec
import EventSourcedBehaviorRecoveryTimeoutSpec._
val pidCounter = new AtomicInteger(0)
- private def nextPid(): PersistenceId =
PersistenceId.ofUniqueId(s"c${pidCounter.incrementAndGet()})")
+ private def nextPid(): PersistenceId =
PersistenceId.ofUniqueId(s"c${pidCounter.incrementAndGet()}")
import org.apache.pekko.actor.typed.scaladsl.adapter._
// needed for SteppingInmemJournal.step
diff --git
a/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorReplySpec.scala
b/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorReplySpec.scala
index a9e6eee6d2..6ab5b4db20 100644
---
a/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorReplySpec.scala
+++
b/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorReplySpec.scala
@@ -82,7 +82,7 @@ class EventSourcedBehaviorReplySpec
import EventSourcedBehaviorReplySpec._
val pidCounter = new AtomicInteger(0)
- private def nextPid(): PersistenceId =
PersistenceId.ofUniqueId(s"c${pidCounter.incrementAndGet()})")
+ private def nextPid(): PersistenceId =
PersistenceId.ofUniqueId(s"c${pidCounter.incrementAndGet()}")
"A typed persistent actor with commands that are expecting replies" must {
diff --git
a/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorRetentionSpec.scala
b/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorRetentionSpec.scala
index 8016af6328..9aae31ac39 100644
---
a/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorRetentionSpec.scala
+++
b/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorRetentionSpec.scala
@@ -135,7 +135,7 @@ class EventSourcedBehaviorRetentionSpec
import EventSourcedBehaviorRetentionSpec._
val pidCounter = new AtomicInteger(0)
- private def nextPid(): PersistenceId =
PersistenceId.ofUniqueId(s"c${pidCounter.incrementAndGet()})")
+ private def nextPid(): PersistenceId =
PersistenceId.ofUniqueId(s"c${pidCounter.incrementAndGet()}")
"EventSourcedBehavior with retention" must {
diff --git
a/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorSpec.scala
b/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorSpec.scala
index e764d2805d..c19a16fa75 100644
---
a/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorSpec.scala
+++
b/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorSpec.scala
@@ -301,7 +301,7 @@ class EventSourcedBehaviorSpec
PersistenceQuery(system).readJournalFor[PersistenceTestKitReadJournal](PersistenceTestKitReadJournal.Identifier)
val pidCounter = new AtomicInteger(0)
- private def nextPid(): PersistenceId =
PersistenceId.ofUniqueId(s"c${pidCounter.incrementAndGet()})")
+ private def nextPid(): PersistenceId =
PersistenceId.ofUniqueId(s"c${pidCounter.incrementAndGet()}")
"A typed persistent actor" must {
diff --git
a/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorStashSpec.scala
b/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorStashSpec.scala
index e9b5d2215b..6ca4190281 100644
---
a/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorStashSpec.scala
+++
b/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorStashSpec.scala
@@ -183,7 +183,7 @@ class EventSourcedBehaviorStashSpec
import EventSourcedBehaviorStashSpec._
val pidCounter = new AtomicInteger(0)
- private def nextPid(): PersistenceId =
PersistenceId.ofUniqueId(s"c${pidCounter.incrementAndGet()})")
+ private def nextPid(): PersistenceId =
PersistenceId.ofUniqueId(s"c${pidCounter.incrementAndGet()}")
"A typed persistent actor that is stashing commands" must {
diff --git
a/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorTimersSpec.scala
b/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorTimersSpec.scala
index 1dee8d80f8..09620e01f7 100644
---
a/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorTimersSpec.scala
+++
b/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorTimersSpec.scala
@@ -83,7 +83,7 @@ class EventSourcedBehaviorTimersSpec
import EventSourcedBehaviorTimersSpec._
val pidCounter = new AtomicInteger(0)
- private def nextPid(): PersistenceId =
PersistenceId.ofUniqueId(s"c${pidCounter.incrementAndGet()})")
+ private def nextPid(): PersistenceId =
PersistenceId.ofUniqueId(s"c${pidCounter.incrementAndGet()}")
"EventSourcedBehavior withTimers" must {
diff --git
a/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedEventAdapterSpec.scala
b/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedEventAdapterSpec.scala
index d654265d70..46cb73542b 100644
---
a/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedEventAdapterSpec.scala
+++
b/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedEventAdapterSpec.scala
@@ -96,7 +96,7 @@ class EventSourcedEventAdapterSpec
import EventSourcedEventAdapterSpec._
val pidCounter = new AtomicInteger(0)
- private def nextPid(): PersistenceId =
PersistenceId.ofUniqueId(s"c${pidCounter.incrementAndGet()})")
+ private def nextPid(): PersistenceId =
PersistenceId.ofUniqueId(s"c${pidCounter.incrementAndGet()}")
val queries: PersistenceTestKitReadJournal =
PersistenceQuery(system).readJournalFor[PersistenceTestKitReadJournal](PersistenceTestKitReadJournal.Identifier)
diff --git
a/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedSnapshotAdapterSpec.scala
b/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedSnapshotAdapterSpec.scala
index 35ec3a37b8..1c94f1193d 100644
---
a/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedSnapshotAdapterSpec.scala
+++
b/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedSnapshotAdapterSpec.scala
@@ -48,7 +48,7 @@ class EventSourcedSnapshotAdapterSpec
import pekko.actor.typed.scaladsl.adapter._
val pidCounter = new AtomicInteger(0)
- private def nextPid(): PersistenceId =
PersistenceId.ofUniqueId(s"c${pidCounter.incrementAndGet()})")
+ private def nextPid(): PersistenceId =
PersistenceId.ofUniqueId(s"c${pidCounter.incrementAndGet()}")
val queries: PersistenceTestKitReadJournal =
PersistenceQuery(system.toClassic)
diff --git
a/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/LoggerSourceSpec.scala
b/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/LoggerSourceSpec.scala
index 8fa974ad6f..a007e2b7cd 100644
---
a/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/LoggerSourceSpec.scala
+++
b/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/LoggerSourceSpec.scala
@@ -37,7 +37,7 @@ class LoggerSourceSpec
with LogCapturing {
private val pidCounter = new AtomicInteger(0)
- private def nextPid(): PersistenceId =
PersistenceId.ofUniqueId(s"c${pidCounter.incrementAndGet()})")
+ private def nextPid(): PersistenceId =
PersistenceId.ofUniqueId(s"c${pidCounter.incrementAndGet()}")
def behavior: Behavior[String] = Behaviors.setup { ctx =>
ctx.log.info("setting-up-behavior")
diff --git
a/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/SnapshotMutableStateSpec.scala
b/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/SnapshotMutableStateSpec.scala
index 051197386f..23727ddcaa 100644
---
a/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/SnapshotMutableStateSpec.scala
+++
b/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/SnapshotMutableStateSpec.scala
@@ -87,7 +87,7 @@ class SnapshotMutableStateSpec
import SnapshotMutableStateSpec._
val pidCounter = new AtomicInteger(0)
- private def nextPid(): PersistenceId =
PersistenceId.ofUniqueId(s"c${pidCounter.incrementAndGet()})")
+ private def nextPid(): PersistenceId =
PersistenceId.ofUniqueId(s"c${pidCounter.incrementAndGet()}")
"A typed persistent actor with mutable state" must {
diff --git
a/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/state/scaladsl/DurableStateBehaviorInterceptorSpec.scala
b/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/state/scaladsl/DurableStateBehaviorInterceptorSpec.scala
index 2437d59388..249c68be28 100644
---
a/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/state/scaladsl/DurableStateBehaviorInterceptorSpec.scala
+++
b/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/state/scaladsl/DurableStateBehaviorInterceptorSpec.scala
@@ -58,7 +58,7 @@ class DurableStateBehaviorInterceptorSpec
import DurableStateBehaviorInterceptorSpec._
val pidCounter = new AtomicInteger(0)
- private def nextPid(): PersistenceId =
PersistenceId.ofUniqueId(s"c${pidCounter.incrementAndGet()})")
+ private def nextPid(): PersistenceId =
PersistenceId.ofUniqueId(s"c${pidCounter.incrementAndGet()}")
"DurableStateBehavior interceptor" must {
diff --git
a/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/state/scaladsl/DurableStateBehaviorReplySpec.scala
b/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/state/scaladsl/DurableStateBehaviorReplySpec.scala
index 0a77d5f646..e0cace3710 100644
---
a/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/state/scaladsl/DurableStateBehaviorReplySpec.scala
+++
b/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/state/scaladsl/DurableStateBehaviorReplySpec.scala
@@ -90,7 +90,7 @@ class DurableStateBehaviorReplySpec
import DurableStateBehaviorReplySpec._
val pidCounter = new AtomicInteger(0)
- private def nextPid(): PersistenceId =
PersistenceId.ofUniqueId(s"c${pidCounter.incrementAndGet()})")
+ private def nextPid(): PersistenceId =
PersistenceId.ofUniqueId(s"c${pidCounter.incrementAndGet()}")
"A typed persistent actor with commands that are expecting replies" must {
diff --git
a/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/state/scaladsl/DurableStateBehaviorTimersSpec.scala
b/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/state/scaladsl/DurableStateBehaviorTimersSpec.scala
index 2f8848f84d..8730dda213 100644
---
a/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/state/scaladsl/DurableStateBehaviorTimersSpec.scala
+++
b/persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/state/scaladsl/DurableStateBehaviorTimersSpec.scala
@@ -86,7 +86,7 @@ class DurableStateBehaviorTimersSpec
import DurableStateBehaviorTimersSpec._
val pidCounter = new AtomicInteger(0)
- private def nextPid(): PersistenceId =
PersistenceId.ofUniqueId(s"c${pidCounter.incrementAndGet()})")
+ private def nextPid(): PersistenceId =
PersistenceId.ofUniqueId(s"c${pidCounter.incrementAndGet()}")
"DurableStateBehavior withTimers" must {
diff --git
a/persistence-typed/src/test/scala/org/apache/pekko/persistence/typed/delivery/EventSourcedProducerQueueSpec.scala
b/persistence-typed/src/test/scala/org/apache/pekko/persistence/typed/delivery/EventSourcedProducerQueueSpec.scala
index 470f67a280..795e739111 100644
---
a/persistence-typed/src/test/scala/org/apache/pekko/persistence/typed/delivery/EventSourcedProducerQueueSpec.scala
+++
b/persistence-typed/src/test/scala/org/apache/pekko/persistence/typed/delivery/EventSourcedProducerQueueSpec.scala
@@ -55,7 +55,7 @@ class EventSourcedProducerQueueSpec
with LogCapturing {
private val pidCounter = new AtomicInteger(0)
- private def nextPid(): PersistenceId =
PersistenceId.ofUniqueId(s"pid-${pidCounter.incrementAndGet()})")
+ private def nextPid(): PersistenceId =
PersistenceId.ofUniqueId(s"pid-${pidCounter.incrementAndGet()}")
private val journalOperations = createTestProbe[InmemJournal.Operation]()
system.eventStream ! EventStream.Subscribe(journalOperations.ref)
diff --git
a/persistence-typed/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/SnapshotIsOptionalSpec.scala
b/persistence-typed/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/SnapshotIsOptionalSpec.scala
index 1bb7ca59d4..80fb489441 100644
---
a/persistence-typed/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/SnapshotIsOptionalSpec.scala
+++
b/persistence-typed/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/SnapshotIsOptionalSpec.scala
@@ -55,7 +55,7 @@ class SnapshotIsOptionalSpec
import SnapshotIsOptionalSpec._
val pidCounter = new AtomicInteger(0)
- private def nextPid(): PersistenceId =
PersistenceId.ofUniqueId(s"c${pidCounter.incrementAndGet()})")
+ private def nextPid(): PersistenceId =
PersistenceId.ofUniqueId(s"c${pidCounter.incrementAndGet()}")
private def behavior(pid: PersistenceId, probe: ActorRef[State1]):
EventSourcedBehavior[Command, Event, State1] =
EventSourcedBehavior[Command, Event, State1](
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
