This is an automated email from the ASF dual-hosted git repository.
He-Pin 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 bf96f5afa6 fix: correct typos in comments, docs, and string literals
across codebase (#3055)
bf96f5afa6 is described below
commit bf96f5afa6440a507f6896b9b1d073d096473a61
Author: He-Pin(kerr) <[email protected]>
AuthorDate: Thu Jun 11 11:53:36 2026 +0800
fix: correct typos in comments, docs, and string literals across codebase
(#3055)
* fix: correct typos in comments, docs, and string literals across codebase
Motivation:
Multiple duplicated words ('the the', 'be be', 'with with', 'for for', etc.)
and a misspelling ('propagagate') scattered across source code comments,
documentation, and log message strings.
Modification:
- Remove duplicated words in comments, scaladoc, and string literals
across 43 files (54 occurrences total)
- Fix 'propagagate' → 'propagate' in GraphUnzipWithSpec test name
- Fix 'to to' → 'to do' in ShardCoordinator scaladoc
Result:
Cleaner documentation and comments with no duplicated words or misspellings.
Tests:
- Not run - docs/comments only
References:
None - typo cleanup
* style: apply scalafmt formatting to ReachabilityPerfSpec
Tests:
- Not run - formatting only
References:
Part of typo fix cleanup
---
.../pekko/actor/testkit/typed/javadsl/BehaviorTestKit.scala | 2 +-
.../org/apache/pekko/actor/testkit/typed/javadsl/TestInbox.scala | 2 +-
.../org/apache/pekko/actor/testkit/typed/scaladsl/TestInbox.scala | 2 +-
.../scala/org/apache/pekko/io/UdpConnectedIntegrationSpec.scala | 2 +-
.../test/scala/org/apache/pekko/serialization/SerializeSpec.scala | 2 +-
.../main/scala/org/apache/pekko/actor/typed/SpawnProtocol.scala | 2 +-
.../delivery/internal/WorkPullingProducerControllerImpl.scala | 2 +-
actor/src/main/resources/reference.conf | 2 +-
actor/src/main/scala/org/apache/pekko/actor/Stash.scala | 2 +-
.../scala/org/apache/pekko/actor/dungeon/TimerSchedulerImpl.scala | 2 +-
.../cluster/sharding/typed/ShardedDaemonProcessSettings.scala | 2 +-
.../typed/delivery/internal/ShardingProducerControllerImpl.scala | 2 +-
.../sharding/typed/delivery/ReliableDeliveryShardingSpec.scala | 2 +-
.../org/apache/pekko/cluster/sharding/ShardCoordinator.scala | 2 +-
.../pekko/cluster/sharding/ConcurrentStartupShardingSpec.scala | 2 +-
.../pekko/cluster/sharding/PersistentShardingMigrationSpec.scala | 2 +-
.../apache/pekko/cluster/singleton/ClusterSingletonManager.scala | 2 +-
.../cluster/ddata/typed/javadsl/ReplicatorMessageAdapter.scala | 8 ++++----
.../cluster/ddata/typed/scaladsl/ReplicatorMessageAdapter.scala | 8 ++++----
cluster/src/main/scala/org/apache/pekko/cluster/Cluster.scala | 4 ++--
.../main/scala/org/apache/pekko/cluster/sbr/DowningStrategy.scala | 2 +-
.../org/apache/pekko/cluster/JoinConfigCompatCheckerSpec.scala | 4 ++--
.../scala/org/apache/pekko/cluster/ReachabilityPerfSpec.scala | 2 +-
.../scala/org/apache/pekko/discovery/dns/DnsDiscoverySpec.scala | 2 +-
.../main/scala/org/apache/pekko/cluster/ddata/Replicator.scala | 2 +-
docs/src/main/paradox/discovery/index.md | 2 +-
docs/src/main/paradox/serialization-jackson.md | 2 +-
.../src/main/paradox/stream/operators/Source-or-Flow/alsoToAll.md | 2 +-
docs/src/main/paradox/stream/stream-refs.md | 2 +-
docs/src/main/paradox/typed/cluster-sharding.md | 2 +-
docs/src/main/paradox/typed/cluster-singleton.md | 6 +++---
docs/src/main/paradox/typed/distributed-data.md | 2 +-
docs/src/main/paradox/typed/persistence-snapshot.md | 2 +-
docs/src/main/paradox/typed/persistence-testing.md | 2 +-
docs/src/main/paradox/typed/style-guide.md | 2 +-
.../pekko/persistence/typed/javadsl/PersistentFSMMigration.scala | 2 +-
.../pekko/persistence/typed/scaladsl/PersistentFSMMigration.scala | 2 +-
remote/src/main/resources/reference.conf | 2 +-
.../apache/pekko/serialization/jackson/JacksonSerializer.scala | 2 +-
.../apache/pekko/serialization/jackson3/JacksonSerializer.scala | 2 +-
.../org/apache/pekko/stream/scaladsl/GraphUnzipWithSpec.scala | 2 +-
.../test/scala/org/apache/pekko/stream/scaladsl/RestartSpec.scala | 4 ++--
.../src/test/scala/org/apache/pekko/testkit/PekkoSpecSpec.scala | 2 +-
43 files changed, 54 insertions(+), 54 deletions(-)
diff --git
a/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/javadsl/BehaviorTestKit.scala
b/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/javadsl/BehaviorTestKit.scala
index 2a97e31323..8057b0e8e6 100644
---
a/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/javadsl/BehaviorTestKit.scala
+++
b/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/javadsl/BehaviorTestKit.scala
@@ -177,7 +177,7 @@ abstract class BehaviorTestKit[T] {
def expectEffect(expectedEffect: Effect): Unit
/**
- * Asserts that the oldest effect is an instance of of class T. Consumes and
returns the concrete effect for
+ * Asserts that the oldest effect is an instance of class T. Consumes and
returns the concrete effect for
* further direct assertions.
*/
def expectEffectClass[U <: Effect](effectClass: Class[U]): U
diff --git
a/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/javadsl/TestInbox.scala
b/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/javadsl/TestInbox.scala
index bc4467aca4..69876fc9b4 100644
---
a/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/javadsl/TestInbox.scala
+++
b/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/javadsl/TestInbox.scala
@@ -62,7 +62,7 @@ abstract class TestInbox[T] {
def receiveMessage(): T
/**
- * Assert and remove the the oldest message.
+ * Assert and remove the oldest message.
*/
def expectMessage(expectedMessage: T): TestInbox[T]
diff --git
a/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/scaladsl/TestInbox.scala
b/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/scaladsl/TestInbox.scala
index f619499835..8b9086344e 100644
---
a/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/scaladsl/TestInbox.scala
+++
b/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/scaladsl/TestInbox.scala
@@ -61,7 +61,7 @@ trait TestInbox[T] {
def receiveMessage(): T
/**
- * Assert and remove the the oldest message.
+ * Assert and remove the oldest message.
*/
def expectMessage(expectedMessage: T): TestInbox[T]
diff --git
a/actor-tests/src/test/scala/org/apache/pekko/io/UdpConnectedIntegrationSpec.scala
b/actor-tests/src/test/scala/org/apache/pekko/io/UdpConnectedIntegrationSpec.scala
index d509c55958..686cd47136 100644
---
a/actor-tests/src/test/scala/org/apache/pekko/io/UdpConnectedIntegrationSpec.scala
+++
b/actor-tests/src/test/scala/org/apache/pekko/io/UdpConnectedIntegrationSpec.scala
@@ -162,7 +162,7 @@ class UdpConnectedIntegrationSpec extends PekkoSpec("""
clientCommander ! UdpConnected.Send(ByteString("data to trigger fail"),
2)
expectMsg(2)
- // when a new server appears at the same port it it should be able to
receive
+ // when a new server appears at the same port it should be able to
receive
val serverIncarnation2Handler = TestProbe()
val serverIncarnation2 = bindUdp(serverAddress,
serverIncarnation2Handler.ref)
val dataToNewIncarnation = ByteString("Data to new incarnation")
diff --git
a/actor-tests/src/test/scala/org/apache/pekko/serialization/SerializeSpec.scala
b/actor-tests/src/test/scala/org/apache/pekko/serialization/SerializeSpec.scala
index 4248da6a68..a94ba68368 100644
---
a/actor-tests/src/test/scala/org/apache/pekko/serialization/SerializeSpec.scala
+++
b/actor-tests/src/test/scala/org/apache/pekko/serialization/SerializeSpec.scala
@@ -223,7 +223,7 @@ class SerializeSpec extends
PekkoSpec(SerializationTests.serializeConf) {
ser.serializerFor(classOf[PlainMessage]).getClass should
===(classOf[NoopSerializer])
}
- "resolve serializer for message extending class with with binding" in {
+ "resolve serializer for message extending class with binding" in {
ser.serializerFor(classOf[ExtendedPlainMessage]).getClass should
===(classOf[NoopSerializer])
}
diff --git
a/actor-typed/src/main/scala/org/apache/pekko/actor/typed/SpawnProtocol.scala
b/actor-typed/src/main/scala/org/apache/pekko/actor/typed/SpawnProtocol.scala
index 3cab20efce..cf792d9a1c 100644
---
a/actor-typed/src/main/scala/org/apache/pekko/actor/typed/SpawnProtocol.scala
+++
b/actor-typed/src/main/scala/org/apache/pekko/actor/typed/SpawnProtocol.scala
@@ -47,7 +47,7 @@ object SpawnProtocol {
* If `name` is an empty string an anonymous actor (with automatically
generated name) will be created.
*
* If the `name` is already taken of an existing actor a unique name will be
used by appending a suffix
- * to the the `name`. The exact format or value of the suffix is an
implementation detail that is
+ * to the `name`. The exact format or value of the suffix is an
implementation detail that is
* undefined. This means that reusing the same name for several actors will
not result in
* `InvalidActorNameException`, but it's better to use unique names to begin
with.
*/
diff --git
a/actor-typed/src/main/scala/org/apache/pekko/actor/typed/delivery/internal/WorkPullingProducerControllerImpl.scala
b/actor-typed/src/main/scala/org/apache/pekko/actor/typed/delivery/internal/WorkPullingProducerControllerImpl.scala
index 4821417087..2e8b008bee 100644
---
a/actor-typed/src/main/scala/org/apache/pekko/actor/typed/delivery/internal/WorkPullingProducerControllerImpl.scala
+++
b/actor-typed/src/main/scala/org/apache/pekko/actor/typed/delivery/internal/WorkPullingProducerControllerImpl.scala
@@ -664,7 +664,7 @@ private class WorkPullingProducerControllerImpl[A:
ClassTag](
case AskTimeout(outKey, outSeqNr) =>
context.log.debug(
- "Message seqNr [{}] sent to worker [{}] timed out. It will be be
redelivered.",
+ "Message seqNr [{}] sent to worker [{}] timed out. It will be
redelivered.",
outSeqNr,
outKey)
Behaviors.same
diff --git a/actor/src/main/resources/reference.conf
b/actor/src/main/resources/reference.conf
index 5b4add60f3..9a7cf7b62c 100644
--- a/actor/src/main/resources/reference.conf
+++ b/actor/src/main/resources/reference.conf
@@ -595,7 +595,7 @@ pekko {
# If the current runtime does not support virtual thread,
# then the executor configured in "fallback" will be used.
virtual-thread-executor {
- #Please set the the underlying pool with system properties below:
+ #Please set the underlying pool with system properties below:
#jdk.virtualThreadScheduler.parallelism
#jdk.virtualThreadScheduler.maxPoolSize
#jdk.virtualThreadScheduler.minRunnable
diff --git a/actor/src/main/scala/org/apache/pekko/actor/Stash.scala
b/actor/src/main/scala/org/apache/pekko/actor/Stash.scala
index 823253f0ab..104962a103 100644
--- a/actor/src/main/scala/org/apache/pekko/actor/Stash.scala
+++ b/actor/src/main/scala/org/apache/pekko/actor/Stash.scala
@@ -254,7 +254,7 @@ private[pekko] trait StashSupport {
/**
* INTERNAL API.
*
- * Clears the stash and and returns all envelopes that have not been
unstashed.
+ * Clears the stash and returns all envelopes that have not been unstashed.
*/
@InternalStableApi
private[pekko] def clearStash(): Vector[Envelope] = {
diff --git
a/actor/src/main/scala/org/apache/pekko/actor/dungeon/TimerSchedulerImpl.scala
b/actor/src/main/scala/org/apache/pekko/actor/dungeon/TimerSchedulerImpl.scala
index f5a973ef63..e1ea980f3c 100644
---
a/actor/src/main/scala/org/apache/pekko/actor/dungeon/TimerSchedulerImpl.scala
+++
b/actor/src/main/scala/org/apache/pekko/actor/dungeon/TimerSchedulerImpl.scala
@@ -149,7 +149,7 @@ import pekko.util.OptionVal
} else {
// it was from an old timer that was enqueued in mailbox before
canceled
log.debug(
- "Received timer [{}] from from old generation [{}], expected
generation [{}], discarding",
+ "Received timer [{}] from old generation [{}], expected generation
[{}], discarding",
timerMsg.key,
timerMsg.generation,
t.generation)
diff --git
a/cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/ShardedDaemonProcessSettings.scala
b/cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/ShardedDaemonProcessSettings.scala
index 3224d1674e..b64fc1930d 100644
---
a/cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/ShardedDaemonProcessSettings.scala
+++
b/cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/ShardedDaemonProcessSettings.scala
@@ -88,7 +88,7 @@ final class ShardedDaemonProcessSettings @InternalApi
private[pekko] (
/**
* Specifies that the ShardedDaemonProcess should run on nodes with a
specific role.
* If the role is not specified all nodes in the cluster are used. If the
given role does
- * not match the role of the current node the the ShardedDaemonProcess will
not be started.
+ * not match the role of the current node the ShardedDaemonProcess will not
be started.
*/
def withRole(role: String): ShardedDaemonProcessSettings =
copy(role = Option(role))
diff --git
a/cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/delivery/internal/ShardingProducerControllerImpl.scala
b/cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/delivery/internal/ShardingProducerControllerImpl.scala
index b105fcdf12..1778f005a0 100644
---
a/cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/delivery/internal/ShardingProducerControllerImpl.scala
+++
b/cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/delivery/internal/ShardingProducerControllerImpl.scala
@@ -573,7 +573,7 @@ private class ShardingProducerControllerImpl[A: ClassTag](
case AskTimeout(outKey, outSeqNr) =>
context.log.debug(
- "Message seqNr [{}] sent to entity [{}] timed out. It will be be
redelivered.",
+ "Message seqNr [{}] sent to entity [{}] timed out. It will be
redelivered.",
outSeqNr,
outKey)
Behaviors.same
diff --git
a/cluster-sharding-typed/src/test/scala/org/apache/pekko/cluster/sharding/typed/delivery/ReliableDeliveryShardingSpec.scala
b/cluster-sharding-typed/src/test/scala/org/apache/pekko/cluster/sharding/typed/delivery/ReliableDeliveryShardingSpec.scala
index 56a30704ee..e05cf0d23d 100644
---
a/cluster-sharding-typed/src/test/scala/org/apache/pekko/cluster/sharding/typed/delivery/ReliableDeliveryShardingSpec.scala
+++
b/cluster-sharding-typed/src/test/scala/org/apache/pekko/cluster/sharding/typed/delivery/ReliableDeliveryShardingSpec.scala
@@ -305,7 +305,7 @@ class ReliableDeliveryShardingSpec
next8.entitiesWithDemand should ===(Set("entity-2"))
next8.bufferedForEntitiesWithoutDemand should ===(Map("entity-1" -> 1))
- // when new demand the buffered messages will be be sent
+ // when new demand the buffered messages will be sent
seq5.producerController ! ProducerControllerImpl.Request(confirmedSeqNr
= 5L, requestUpToSeqNr = 10, true, false)
val seq6 = shardingProbe
.fishForMessage(testKit.testKitSettings.dilated(3.seconds), "waiting
for buffered msg-6 after renewed demand") {
diff --git
a/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/ShardCoordinator.scala
b/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/ShardCoordinator.scala
index 538f5cde2d..b079f98d43 100644
---
a/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/ShardCoordinator.scala
+++
b/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/ShardCoordinator.scala
@@ -171,7 +171,7 @@ object ShardCoordinator {
/**
* Shard allocation strategy where start is called by the shard coordinator
before any calls to
* rebalance or allocate shard. This can be used if there is any expensive
initialization to be done
- * that you do not want to to in the constructor as it will happen on every
node rather than just
+ * that you do not want to do in the constructor as it will happen on every
node rather than just
* the node that hosts the ShardCoordinator
*/
trait StartableAllocationStrategy extends ShardAllocationStrategy {
diff --git
a/cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/ConcurrentStartupShardingSpec.scala
b/cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/ConcurrentStartupShardingSpec.scala
index 37463335bc..ea8ae11bb4 100644
---
a/cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/ConcurrentStartupShardingSpec.scala
+++
b/cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/ConcurrentStartupShardingSpec.scala
@@ -78,7 +78,7 @@ class ConcurrentStartupShardingSpec extends
PekkoSpec(ConcurrentStartupShardingS
if (!log.isDebugEnabled)
system.eventStream.publish(Mute(DeadLettersFilter[Any]))
- // The intended usage is to start sharding in one (or a few) places when the
the ActorSystem
+ // The intended usage is to start sharding in one (or a few) places when the
ActorSystem
// is started and not to do it concurrently from many threads. However, we
can do our best and when using
// FJP the Await will create additional threads when needed.
"Concurrent Sharding startup" must {
diff --git
a/cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/PersistentShardingMigrationSpec.scala
b/cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/PersistentShardingMigrationSpec.scala
index 49edf1ccbf..6d7c4ced17 100644
---
a/cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/PersistentShardingMigrationSpec.scala
+++
b/cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/PersistentShardingMigrationSpec.scala
@@ -42,7 +42,7 @@ object PersistentShardingMigrationSpec {
remember-entities-store = "eventsourced"
# this forces the remembered entity store to use persistence
- # is is deprecated
+ # is deprecated
state-store-mode = "persistence"
# make sure we test snapshots
diff --git
a/cluster-tools/src/main/scala/org/apache/pekko/cluster/singleton/ClusterSingletonManager.scala
b/cluster-tools/src/main/scala/org/apache/pekko/cluster/singleton/ClusterSingletonManager.scala
index 6a1a2bf6ee..0fca6107e3 100644
---
a/cluster-tools/src/main/scala/org/apache/pekko/cluster/singleton/ClusterSingletonManager.scala
+++
b/cluster-tools/src/main/scala/org/apache/pekko/cluster/singleton/ClusterSingletonManager.scala
@@ -219,7 +219,7 @@ object ClusterSingletonManager {
case object HandOverDone extends ClusterSingletonMessage
/**
- * Sent from from previous oldest to new oldest to
+ * Sent from previous oldest to new oldest to
* initiate the normal hand-over process.
* Especially useful when new node joins and becomes
* oldest immediately, without knowing who was previous
diff --git
a/cluster-typed/src/main/scala/org/apache/pekko/cluster/ddata/typed/javadsl/ReplicatorMessageAdapter.scala
b/cluster-typed/src/main/scala/org/apache/pekko/cluster/ddata/typed/javadsl/ReplicatorMessageAdapter.scala
index 3910c3b088..8fbaa0f835 100644
---
a/cluster-typed/src/main/scala/org/apache/pekko/cluster/ddata/typed/javadsl/ReplicatorMessageAdapter.scala
+++
b/cluster-typed/src/main/scala/org/apache/pekko/cluster/ddata/typed/javadsl/ReplicatorMessageAdapter.scala
@@ -101,7 +101,7 @@ class ReplicatorMessageAdapter[A, B <: ReplicatedData](
* `responseAdapter` function.
*
* Note that `createRequest` is a function that creates the `Update` message
from the provided
- * `ActorRef[UpdateResponse]` that the the replicator will send the response
message back through.
+ * `ActorRef[UpdateResponse]` that the replicator will send the response
message back through.
* Use that `ActorRef[UpdateResponse]` as the `replyTo` parameter in the
`Update` message.
*/
def askUpdate(
@@ -120,7 +120,7 @@ class ReplicatorMessageAdapter[A, B <: ReplicatedData](
* `responseAdapter` function.
*
* Note that `createRequest` is a function that creates the `Get` message
from the provided
- * `ActorRef[GetResponse]` that the the replicator will send the response
message back through.
+ * `ActorRef[GetResponse]` that the replicator will send the response
message back through.
* Use that `ActorRef[GetResponse]` as the `replyTo` parameter in the `Get`
message.
*/
@nowarn
@@ -140,7 +140,7 @@ class ReplicatorMessageAdapter[A, B <: ReplicatedData](
* `responseAdapter` function.
*
* Note that `createRequest` is a function that creates the `Delete` message
from the provided
- * `ActorRef[DeleteResponse]` that the the replicator will send the response
message back through.
+ * `ActorRef[DeleteResponse]` that the replicator will send the response
message back through.
* Use that `ActorRef[DeleteResponse]` as the `replyTo` parameter in the
`Delete` message.
*/
def askDelete(
@@ -159,7 +159,7 @@ class ReplicatorMessageAdapter[A, B <: ReplicatedData](
* `responseAdapter` function.
*
* Note that `createRequest` is a function that creates the
`GetReplicaCount` message from the provided
- * `ActorRef[ReplicaCount]` that the the replicator will send the response
message back through.
+ * `ActorRef[ReplicaCount]` that the replicator will send the response
message back through.
* Use that `ActorRef[ReplicaCount]` as the `replyTo` parameter in the
`GetReplicaCount` message.
*/
def askReplicaCount(
diff --git
a/cluster-typed/src/main/scala/org/apache/pekko/cluster/ddata/typed/scaladsl/ReplicatorMessageAdapter.scala
b/cluster-typed/src/main/scala/org/apache/pekko/cluster/ddata/typed/scaladsl/ReplicatorMessageAdapter.scala
index 2544515e80..e30ba2a1fb 100644
---
a/cluster-typed/src/main/scala/org/apache/pekko/cluster/ddata/typed/scaladsl/ReplicatorMessageAdapter.scala
+++
b/cluster-typed/src/main/scala/org/apache/pekko/cluster/ddata/typed/scaladsl/ReplicatorMessageAdapter.scala
@@ -104,7 +104,7 @@ class ReplicatorMessageAdapter[A, B <: ReplicatedData](
* `responseAdapter` function.
*
* Note that `createRequest` is a function that creates the `Update` message
from the provided
- * `ActorRef[UpdateResponse]` that the the replicator will send the response
message back through.
+ * `ActorRef[UpdateResponse]` that the replicator will send the response
message back through.
* Use that `ActorRef[UpdateResponse]` as the `replyTo` parameter in the
`Update` message.
*/
def askUpdate(
@@ -123,7 +123,7 @@ class ReplicatorMessageAdapter[A, B <: ReplicatedData](
* `responseAdapter` function.
*
* Note that `createRequest` is a function that creates the `Get` message
from the provided
- * `ActorRef[GetResponse]` that the the replicator will send the response
message back through.
+ * `ActorRef[GetResponse]` that the replicator will send the response
message back through.
* Use that `ActorRef[GetResponse]` as the `replyTo` parameter in the `Get`
message.
*/
def askGet(
@@ -141,7 +141,7 @@ class ReplicatorMessageAdapter[A, B <: ReplicatedData](
* `responseAdapter` function.
*
* Note that `createRequest` is a function that creates the `Delete` message
from the provided
- * `ActorRef[DeleteResponse]` that the the replicator will send the response
message back through.
+ * `ActorRef[DeleteResponse]` that the replicator will send the response
message back through.
* Use that `ActorRef[DeleteResponse]` as the `replyTo` parameter in the
`Delete` message.
*/
def askDelete(
@@ -160,7 +160,7 @@ class ReplicatorMessageAdapter[A, B <: ReplicatedData](
* `responseAdapter` function.
*
* Note that `createRequest` is a function that creates the
`GetReplicaCount` message from the provided
- * `ActorRef[ReplicaCount]` that the the replicator will send the response
message back through.
+ * `ActorRef[ReplicaCount]` that the replicator will send the response
message back through.
* Use that `ActorRef[ReplicaCount]` as the `replyTo` parameter in the
`GetReplicaCount` message.
*/
def askReplicaCount(
diff --git a/cluster/src/main/scala/org/apache/pekko/cluster/Cluster.scala
b/cluster/src/main/scala/org/apache/pekko/cluster/Cluster.scala
index 1fd9bd911b..2a13a1a455 100644
--- a/cluster/src/main/scala/org/apache/pekko/cluster/Cluster.scala
+++ b/cluster/src/main/scala/org/apache/pekko/cluster/Cluster.scala
@@ -452,7 +452,7 @@ class Cluster(val system: ExtendedActorSystem) extends
Extension {
/**
* The supplied thunk will be run, once, when current cluster member is
`Removed`.
* If the cluster has already been shutdown the thunk will run on the caller
thread immediately.
- * If this is called "at the same time" as `shutdown()` there is a
possibility that the the thunk
+ * If this is called "at the same time" as `shutdown()` there is a
possibility that the thunk
* is not invoked. It's often better to use
[[pekko.actor.CoordinatedShutdown]] for this purpose.
*/
def registerOnMemberRemoved[T](code: => T): Unit =
@@ -461,7 +461,7 @@ class Cluster(val system: ExtendedActorSystem) extends
Extension {
/**
* Java API: The supplied thunk will be run, once, when current cluster
member is `Removed`.
* If the cluster has already been shutdown the thunk will run on the caller
thread immediately.
- * If this is called "at the same time" as `shutdown()` there is a
possibility that the the thunk
+ * If this is called "at the same time" as `shutdown()` there is a
possibility that the thunk
* is not invoked. It's often better to use
[[pekko.actor.CoordinatedShutdown]] for this purpose.
*/
def registerOnMemberRemoved(callback: Runnable): Unit = {
diff --git
a/cluster/src/main/scala/org/apache/pekko/cluster/sbr/DowningStrategy.scala
b/cluster/src/main/scala/org/apache/pekko/cluster/sbr/DowningStrategy.scala
index 4de96915bf..ccc209d5e2 100644
--- a/cluster/src/main/scala/org/apache/pekko/cluster/sbr/DowningStrategy.scala
+++ b/cluster/src/main/scala/org/apache/pekko/cluster/sbr/DowningStrategy.scala
@@ -392,7 +392,7 @@ import pekko.coordination.lease.scaladsl.Lease
* INTERNAL API
*
* Down the unreachable nodes if the current node is in the majority part
based the last known
- * membership information. Otherwise down the reachable nodes, i.e. the own
part. If the the
+ * membership information. Otherwise down the reachable nodes, i.e. the own
part. If the
* parts are of equal size the part containing the node with the lowest
address is kept.
*
* If the `role` is defined the decision is based only on members with that
`role`.
diff --git
a/cluster/src/test/scala/org/apache/pekko/cluster/JoinConfigCompatCheckerSpec.scala
b/cluster/src/test/scala/org/apache/pekko/cluster/JoinConfigCompatCheckerSpec.scala
index 086a42f1e7..9677f2d459 100644
---
a/cluster/src/test/scala/org/apache/pekko/cluster/JoinConfigCompatCheckerSpec.scala
+++
b/cluster/src/test/scala/org/apache/pekko/cluster/JoinConfigCompatCheckerSpec.scala
@@ -234,7 +234,7 @@ class JoinConfigCompatCheckerSpec extends PekkoSpec with
ClusterTestKit {
"be allowed to join a cluster when its configuration is incompatible but
it's configured to NOT enforce it" taggedAs
LongRunningTest in {
// this config is NOT compatible with the cluster config,
- // but node will ignore the the config check and join anyway
+ // but node will ignore the config check and join anyway
val joinNodeConfig =
ConfigFactory.parseString("""
pekko.cluster {
@@ -523,7 +523,7 @@ class JoinConfigCompatCheckerSpec extends PekkoSpec with
ClusterTestKit {
"be allowed to re-join a cluster when its configuration is incompatible
but it's configured to NOT enforce it" taggedAs
LongRunningTest in {
// this config is NOT compatible with the cluster config,
- // but node will ignore the the config check and join anyway
+ // but node will ignore the config check and join anyway
val joinNodeConfig =
ConfigFactory.parseString("""
pekko.cluster {
diff --git
a/cluster/src/test/scala/org/apache/pekko/cluster/ReachabilityPerfSpec.scala
b/cluster/src/test/scala/org/apache/pekko/cluster/ReachabilityPerfSpec.scala
index 471fb7f8a5..14d5198a6b 100644
--- a/cluster/src/test/scala/org/apache/pekko/cluster/ReachabilityPerfSpec.scala
+++ b/cluster/src/test/scala/org/apache/pekko/cluster/ReachabilityPerfSpec.scala
@@ -92,7 +92,7 @@ class ReachabilityPerfSpec extends AnyWordSpec with Matchers {
private def recordsFrom(r1: Reachability): Unit = {
r1.allObservers.foreach { o =>
- r1.recordsFrom(o) should not be be(null)
+ r1.recordsFrom(o) should not be null
}
}
diff --git
a/discovery/src/test/scala/org/apache/pekko/discovery/dns/DnsDiscoverySpec.scala
b/discovery/src/test/scala/org/apache/pekko/discovery/dns/DnsDiscoverySpec.scala
index 73a9115c27..75f2205230 100644
---
a/discovery/src/test/scala/org/apache/pekko/discovery/dns/DnsDiscoverySpec.scala
+++
b/discovery/src/test/scala/org/apache/pekko/discovery/dns/DnsDiscoverySpec.scala
@@ -115,7 +115,7 @@ class DnsDiscoverySpec extends
DockerBindDnsService(DnsDiscoverySpec.config) {
}
"be using its own resolver" in {
- // future will fail if it it doesn't exist
+ // future will fail if it doesn't exist
system.actorSelection("/system/SD-DNS/async-dns").resolveOne(2.seconds).futureValue
}
diff --git
a/distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/Replicator.scala
b/distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/Replicator.scala
index f9f3f996da..37f622c2ce 100644
---
a/distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/Replicator.scala
+++
b/distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/Replicator.scala
@@ -1101,7 +1101,7 @@ object Replicator {
*
* For good introduction to the CRDT subject watch the
* <a href="https://www.infoq.com/presentations/CRDT/";>Eventually Consistent
Data Structures</a>
- * talk by Sean Cribbs and and the
+ * talk by Sean Cribbs and the
* <a
href="https://www.microsoft.com/en-us/research/video/strong-eventual-consistency-and-conflict-free-replicated-data-types/";>talk
by Mark Shapiro</a>
* and read the excellent paper <a
href="https://hal.inria.fr/file/index/docid/555588/filename/techreport.pdf";>
* A comprehensive study of Convergent and Commutative Replicated Data
Types</a>
diff --git a/docs/src/main/paradox/discovery/index.md
b/docs/src/main/paradox/discovery/index.md
index 9665314174..fda23ccbdc 100644
--- a/docs/src/main/paradox/discovery/index.md
+++ b/docs/src/main/paradox/discovery/index.md
@@ -74,7 +74,7 @@ Pekko Discovery with DNS does always use the
@ref[Pekko-native "async-dns" imple
DNS discovery maps `Lookup` queries as follows:
* `serviceName`, `portName` and `protocol` set: SRV query in the form:
`_port._protocol.name` Where the `_`s are added.
-* Any query missing any of the fields is mapped to a A/AAAA query for the
`serviceName`
+* Any query missing any of the fields is mapped to a A/AAAA query for the
`serviceName`
The mapping between Pekko service discovery terminology and SRV terminology:
diff --git a/docs/src/main/paradox/serialization-jackson.md
b/docs/src/main/paradox/serialization-jackson.md
index 108a753043..b5d8fa5271 100644
--- a/docs/src/main/paradox/serialization-jackson.md
+++ b/docs/src/main/paradox/serialization-jackson.md
@@ -18,7 +18,7 @@ To use Jackson Serialization, you must add the following
dependency in your proj
## Introduction
-You find general concepts for for Pekko serialization in the
@ref:[Serialization](serialization.md) section.
+You find general concepts for Pekko serialization in the
@ref:[Serialization](serialization.md) section.
This section describes how to use the Jackson serializer for application
specific messages and persistent
events and snapshots.
diff --git a/docs/src/main/paradox/stream/operators/Source-or-Flow/alsoToAll.md
b/docs/src/main/paradox/stream/operators/Source-or-Flow/alsoToAll.md
index 29951f9ed6..b2650a8c6c 100644
--- a/docs/src/main/paradox/stream/operators/Source-or-Flow/alsoToAll.md
+++ b/docs/src/main/paradox/stream/operators/Source-or-Flow/alsoToAll.md
@@ -24,7 +24,7 @@ will also be sent to all those @apidoc[Sink]s.
**completes** when upstream completes
-**cancels** when downstream or or any of the @apidoc[Sink]s cancels
+**cancels** when downstream or any of the @apidoc[Sink]s cancels
@@@
diff --git a/docs/src/main/paradox/stream/stream-refs.md
b/docs/src/main/paradox/stream/stream-refs.md
index 40d5f5e019..1f3e5d795c 100644
--- a/docs/src/main/paradox/stream/stream-refs.md
+++ b/docs/src/main/paradox/stream/stream-refs.md
@@ -158,7 +158,7 @@ Stream refs utilise normal actor messaging for their
transport, and therefore pr
- messages are sent over actor remoting
- which relies on TCP (classic remoting or Artery TCP) or Aeron UDP for
basic redelivery mechanisms
-- messages are guaranteed to to be in-order
+- messages are guaranteed to be in-order
- messages can be lost, however:
- a *dropped demand signal* will be re-delivered automatically (similar to
system messages)
- a *dropped element signal* will cause the stream to *fail*
diff --git a/docs/src/main/paradox/typed/cluster-sharding.md
b/docs/src/main/paradox/typed/cluster-sharding.md
index 7a442e1cef..1192a2ce5e 100644
--- a/docs/src/main/paradox/typed/cluster-sharding.md
+++ b/docs/src/main/paradox/typed/cluster-sharding.md
@@ -776,7 +776,7 @@ Reasons for how this can happen:
A lease can be a final backup that means that each shard won't create child
entity actors unless it has the lease.
To use a lease for sharding set `pekko.cluster.sharding.use-lease` to the
configuration location
-of the lease to use. Each shard will try and acquire a lease with with the
name `<actor system name>-shard-<type name>-<shard id>` and
+of the lease to use. Each shard will try and acquire a lease with the name
`<actor system name>-shard-<type name>-<shard id>` and
the owner is set to the `Cluster(system).selfAddress.hostPort`.
If a shard can't acquire a lease it will remain uninitialized so messages for
entities it owns will
diff --git a/docs/src/main/paradox/typed/cluster-singleton.md
b/docs/src/main/paradox/typed/cluster-singleton.md
index c705ad9403..e6c482d313 100644
--- a/docs/src/main/paradox/typed/cluster-singleton.md
+++ b/docs/src/main/paradox/typed/cluster-singleton.md
@@ -38,7 +38,7 @@ instance will eventually be started.
@@@ warning
Make sure to not use a Cluster downing strategy that may split the cluster
into several separate clusters in
-case of network problems or system overload (long GC pauses), since that will
result in in *multiple Singletons*
+case of network problems or system overload (long GC pauses), since that will
result in *multiple Singletons*
being started, one in each separate cluster!
See @ref:[Downing](cluster.md#downing).
@@ -106,7 +106,7 @@ This pattern may seem to be very tempting to use at first,
but it has several dr
@@@ warning
Make sure to not use a Cluster downing strategy that may split the cluster
into several separate clusters in
-case of network problems or system overload (long GC pauses), since that will
result in in *multiple Singletons*
+case of network problems or system overload (long GC pauses), since that will
result in *multiple Singletons*
being started, one in each separate cluster!
See @ref:[Downing](cluster.md#downing).
@@ -175,7 +175,7 @@ A lease can be a final backup that means that the singleton
actor won't be creat
the lease can be acquired.
To use a lease for singleton set `pekko.cluster.singleton.use-lease` to the
configuration location
-of the lease to use. A lease with with the name `<actor system
name>-singleton-<singleton actor path>` is used and
+of the lease to use. A lease with the name `<actor system
name>-singleton-<singleton actor path>` is used and
the owner is set to the
@scala[`Cluster(system).selfAddress.hostPort`]@java[`Cluster.get(system).selfAddress().hostPort()`].
If the cluster singleton manager can't acquire the lease it will keep retrying
while it is the oldest node in the cluster.
diff --git a/docs/src/main/paradox/typed/distributed-data.md
b/docs/src/main/paradox/typed/distributed-data.md
index 84a4104bad..b87ee83822 100644
--- a/docs/src/main/paradox/typed/distributed-data.md
+++ b/docs/src/main/paradox/typed/distributed-data.md
@@ -561,7 +561,7 @@ Note that the full state is occasionally also replicated
for delta-CRDTs, for ex
new nodes are added to the cluster or when deltas could not be propagated
because
of network partitions or similar problems.
-The the delta propagation can be disabled with configuration property:
+The delta propagation can be disabled with configuration property:
```
pekko.cluster.distributed-data.delta-crdt.enabled=off
diff --git a/docs/src/main/paradox/typed/persistence-snapshot.md
b/docs/src/main/paradox/typed/persistence-snapshot.md
index bfc2112d23..799a0932c8 100644
--- a/docs/src/main/paradox/typed/persistence-snapshot.md
+++ b/docs/src/main/paradox/typed/persistence-snapshot.md
@@ -52,7 +52,7 @@ events. This can be useful if snapshot serialization format
has changed in an in
not be used when events have been deleted.
In order to use snapshots, a default snapshot-store
(`pekko.persistence.snapshot-store.plugin`) must be configured,
-or you can pick a snapshot store for for a specific `EventSourcedBehavior` by
+or you can pick a snapshot store for a specific `EventSourcedBehavior` by
@scala[defining it with `withSnapshotPluginId` of the
`EventSourcedBehavior`]@java[overriding `snapshotPluginId` in
the `EventSourcedBehavior`].
diff --git a/docs/src/main/paradox/typed/persistence-testing.md
b/docs/src/main/paradox/typed/persistence-testing.md
index 17ecd576f4..17fe88475f 100644
--- a/docs/src/main/paradox/typed/persistence-testing.md
+++ b/docs/src/main/paradox/typed/persistence-testing.md
@@ -59,7 +59,7 @@ Java
`PersistenceProbeBehavior` does not require any configuration. It therefore
does not verify the serialization of commands, events, or state.
If using this style, it is advised to independently test serialization for
those classes.
-## Unit testing with the the ActorTestKit and EventSourcedBehaviorTestKit
+## Unit testing with the ActorTestKit and EventSourcedBehaviorTestKit
**Note!** The `EventSourcedBehaviorTestKit` is a new feature: the API may have
changes breaking source compatibility in future versions.
diff --git a/docs/src/main/paradox/typed/style-guide.md
b/docs/src/main/paradox/typed/style-guide.md
index 0b90acf6c9..1a23d97728 100644
--- a/docs/src/main/paradox/typed/style-guide.md
+++ b/docs/src/main/paradox/typed/style-guide.md
@@ -45,7 +45,7 @@ A few differences to note:
* There is no class in the functional style, but that is not strictly a
requirement and sometimes it's
convenient to use a class also with the functional style to reduce number of
parameters in the methods.
* Mutable state, such as the @scala[`var n`]@java[`int n`] is typically used
in the object-oriented style.
-* In the functional style the state is is updated by returning a new behavior
that holds the new immutable state,
+* In the functional style the state is updated by returning a new behavior
that holds the new immutable state,
the @scala[`n: Int`]@java[`final int n`] parameter of the `counter` method.
* The object-oriented style must use a new instance of the initial `Behavior`
for each spawned actor instance,
since the state in `AbstractBehavior` instance must not be shared between
actor instances.
diff --git
a/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/javadsl/PersistentFSMMigration.scala
b/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/javadsl/PersistentFSMMigration.scala
index e97c1894b2..0d6266bf38 100644
---
a/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/javadsl/PersistentFSMMigration.scala
+++
b/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/javadsl/PersistentFSMMigration.scala
@@ -32,7 +32,7 @@ object PersistentFSMMigration {
* Create a snapshot adapter that will adapt snapshots created by a
PersistentFSM into
* the correct State type of a [[EventSourcedBehavior]]
* @param adapt Takes in the state identifier, snapshot persisted by the
PersistentFSM and the state timeout and
- * returns the `State` that should be given to the the
[[EventSourcedBehavior]]
+ * returns the `State` that should be given to the
[[EventSourcedBehavior]]
* @tparam State State type of the [[EventSourcedBehavior]]
* @return A [[SnapshotAdapter]] to be used with a [[EventSourcedBehavior]]
*/
diff --git
a/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/scaladsl/PersistentFSMMigration.scala
b/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/scaladsl/PersistentFSMMigration.scala
index dda90f75e2..1cbf619701 100644
---
a/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/scaladsl/PersistentFSMMigration.scala
+++
b/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/scaladsl/PersistentFSMMigration.scala
@@ -28,7 +28,7 @@ object PersistentFSMMigration {
* Create a snapshot adapter that will adapt snapshots created by a
PersistentFSM into
* the correct State type of a [[EventSourcedBehavior]]
* @param adapt Takes in the state identifier, snapshot persisted by the
PersistentFSM and the state timeout and
- * returns the `State` that should be given to the the
[[EventSourcedBehavior]]
+ * returns the `State` that should be given to the
[[EventSourcedBehavior]]
* @tparam State State type of the [[EventSourcedBehavior]]
* @return A [[SnapshotAdapter]] to be used with a [[EventSourcedBehavior]]
*/
diff --git a/remote/src/main/resources/reference.conf
b/remote/src/main/resources/reference.conf
index 2741292ad9..b4bf9bac8e 100644
--- a/remote/src/main/resources/reference.conf
+++ b/remote/src/main/resources/reference.conf
@@ -1235,7 +1235,7 @@ pekko {
# at least one common subject name (CN or SAN).
# The Key setup this implementation supports has some limitations:
# 1. the private key must be provided on a PKCS#1 or a non-encrypted
PKCS#8 PEM-formatted file
- # 2. the private key must be be of an algorithm supported by
`pekko-pki` tools (e.g. "RSA", not "EC")
+ # 2. the private key must be of an algorithm supported by
`pekko-pki` tools (e.g. "RSA", not "EC")
# 3. the node certificate must be issued by a root CA (not an
intermediate CA)
# 4. both the node and the CA certificates must be provided in
PEM-formatted files
rotating-keys-engine {
diff --git
a/serialization-jackson/src/main/scala/org/apache/pekko/serialization/jackson/JacksonSerializer.scala
b/serialization-jackson/src/main/scala/org/apache/pekko/serialization/jackson/JacksonSerializer.scala
index 85ccf11ccf..7c3aac2030 100644
---
a/serialization-jackson/src/main/scala/org/apache/pekko/serialization/jackson/JacksonSerializer.scala
+++
b/serialization-jackson/src/main/scala/org/apache/pekko/serialization/jackson/JacksonSerializer.scala
@@ -175,7 +175,7 @@ import pekko.util.OptionVal
* Configuration in `pekko.serialization.jackson` section.
* It will load Jackson modules defined in configuration `jackson-modules`.
*
- * It will compress the payload if the compression `algorithm` is enabled and
the the
+ * It will compress the payload if the compression `algorithm` is enabled and
the
* payload is larger than the configured `compress-larger-than` value.
*/
@InternalApi private[pekko] abstract class JacksonSerializer(
diff --git
a/serialization-jackson3/src/main/scala/org/apache/pekko/serialization/jackson3/JacksonSerializer.scala
b/serialization-jackson3/src/main/scala/org/apache/pekko/serialization/jackson3/JacksonSerializer.scala
index 1fc675f6d9..01c15ce4d8 100644
---
a/serialization-jackson3/src/main/scala/org/apache/pekko/serialization/jackson3/JacksonSerializer.scala
+++
b/serialization-jackson3/src/main/scala/org/apache/pekko/serialization/jackson3/JacksonSerializer.scala
@@ -175,7 +175,7 @@ import pekko.util.OptionVal
* Configuration in `pekko.serialization.jackson` section.
* It will load Jackson modules defined in configuration `jackson-modules`.
*
- * It will compress the payload if the compression `algorithm` is enabled and
the the
+ * It will compress the payload if the compression `algorithm` is enabled and
the
* payload is larger than the configured `compress-larger-than` value.
*/
@InternalApi private[pekko] abstract class JacksonSerializer(
diff --git
a/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphUnzipWithSpec.scala
b/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphUnzipWithSpec.scala
index c9d8be38d9..159b5c1611 100644
---
a/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphUnzipWithSpec.scala
+++
b/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphUnzipWithSpec.scala
@@ -207,7 +207,7 @@ class GraphUnzipWithSpec extends StreamSpec("""
rightProbe.expectNoMessage(100.millis)
}
- "propagagate last downstream cancellation cause once all downstreams have
cancelled" in {
+ "propagate last downstream cancellation cause once all downstreams have
cancelled" in {
val probe = TestProbe()
RunnableGraph
.fromGraph(GraphDSL.create() { implicit b =>
diff --git
a/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/RestartSpec.scala
b/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/RestartSpec.scala
index 802cd438e9..726f9d382c 100644
---
a/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/RestartSpec.scala
+++
b/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/RestartSpec.scala
@@ -176,7 +176,7 @@ class RestartSpec
probe.requestNext("a")
probe.requestNext("b")
probe.request(1)
- // The probe should now be backing off again with with increased backoff
+ // The probe should now be backing off again with increased backoff
// Now wait for the delay to pass, then it will start the new source, we
also want to wait for the
// subsequent backoff to pass, so it resets the restart count
@@ -314,7 +314,7 @@ class RestartSpec
probe.requestNext("a")
// There should be minBackoff delay
probe.requestNext("a")
- // The probe should now be backing off again with with increased backoff
+ // The probe should now be backing off again with increased backoff
// Now wait for the delay to pass, then it will start the new source, we
also want to wait for the
// subsequent backoff to pass
diff --git
a/testkit/src/test/scala/org/apache/pekko/testkit/PekkoSpecSpec.scala
b/testkit/src/test/scala/org/apache/pekko/testkit/PekkoSpecSpec.scala
index e353d09fd8..c833e4fc27 100644
--- a/testkit/src/test/scala/org/apache/pekko/testkit/PekkoSpecSpec.scala
+++ b/testkit/src/test/scala/org/apache/pekko/testkit/PekkoSpecSpec.scala
@@ -46,7 +46,7 @@ class PekkoSpecSpec extends AnyWordSpec with Matchers {
}
"terminate all actors" in {
- // verbose config just for demonstration purposes, please leave in in
case of debugging
+ // verbose config just for demonstration purposes, please leave in case
of debugging
import scala.jdk.CollectionConverters._
val conf = Map(
"pekko.actor.debug.lifecycle" -> true,
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
