You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by fa...@apache.org on 2025/10/25 13:58:48 UTC
(pekko) branch main updated: Fix typos in Java, Markdown and Scala files (#2371)
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 a7b9dc452c Fix typos in Java, Markdown and Scala files (#2371)
a7b9dc452c is described below
commit a7b9dc452c5426d5736944d30078fa2f69f133ee
Author: John Bampton <jb...@users.noreply.github.com>
AuthorDate: Sat Oct 25 23:58:43 2025 +1000
Fix typos in Java, Markdown and Scala files (#2371)
---
.../test/scala/org/apache/pekko/actor/ExtensionSpec.scala | 4 ++--
.../test/scala/org/apache/pekko/routing/BalancingSpec.scala | 4 ++--
.../org/apache/pekko/util/ByteStringInitializationSpec.scala | 2 +-
.../pekko/actor/typed/internal/adapter/ActorAdapter.scala | 2 +-
.../delivery/internal/ShardingProducerControllerImpl.scala | 4 ++--
.../sharding/ClusterShardingRememberEntitiesPerfSpec.scala | 2 +-
.../org/apache/pekko/cluster/sharding/ShardCoordinator.scala | 4 ++--
.../sharding/internal/LeastShardAllocationStrategy.scala | 2 +-
.../org/apache/pekko/cluster/ddata/ReplicatorSpec.scala | 2 +-
.../main/paradox/stream/operators/Source-or-Flow/collect.md | 2 +-
.../paradox/stream/operators/Source-or-Flow/collectType.md | 2 +-
.../stream/operators/Source-or-Flow/mapAsyncUnordered.md | 10 +++++-----
docs/src/main/paradox/typed/cluster-sharding.md | 2 +-
.../typed/javadsl/EventSourcedBehaviorJavaDslTest.java | 2 +-
.../persistence/typed/scaladsl/EventSourcedBehavior.scala | 2 +-
.../typed/state/scaladsl/DurableStateBehavior.scala | 2 +-
.../org/apache/pekko/remote/artery/EnvelopeBufferPool.scala | 8 ++++----
.../remote/serialization/MiscMessageSerializerSpec.scala | 12 ++++++------
.../apache/pekko/stream/scaladsl/FlowCollectFirstSpec.scala | 2 +-
.../apache/pekko/stream/scaladsl/FlowCollectWhileSpec.scala | 2 +-
.../scala/org/apache/pekko/stream/scaladsl/SinkSpec.scala | 4 ++--
.../scala/org/apache/pekko/stream/QueueOfferResult.scala | 2 +-
.../main/scala/org/apache/pekko/stream/javadsl/Flow.scala | 2 +-
.../main/scala/org/apache/pekko/stream/javadsl/Source.scala | 2 +-
.../main/scala/org/apache/pekko/stream/javadsl/SubFlow.scala | 2 +-
.../scala/org/apache/pekko/stream/javadsl/SubSource.scala | 2 +-
.../scala/org/apache/pekko/stream/scaladsl/Framing.scala | 2 +-
27 files changed, 44 insertions(+), 44 deletions(-)
diff --git a/actor-tests/src/test/scala/org/apache/pekko/actor/ExtensionSpec.scala b/actor-tests/src/test/scala/org/apache/pekko/actor/ExtensionSpec.scala
index 18707cd610..1586d44683 100644
--- a/actor-tests/src/test/scala/org/apache/pekko/actor/ExtensionSpec.scala
+++ b/actor-tests/src/test/scala/org/apache/pekko/actor/ExtensionSpec.scala
@@ -31,7 +31,7 @@ object TestExtension extends ExtensionId[TestExtension] with ExtensionIdProvider
def createExtension(s: ExtendedActorSystem) = new TestExtension(s)
}
-// Dont't place inside ActorSystemSpec object, since it will not be garbage collected and reference to system remains
+// Don't place inside ActorSystemSpec object, since it will not be garbage collected and reference to system remains
class TestExtension(val system: ExtendedActorSystem) extends Extension
object FailingTestExtension extends ExtensionId[FailingTestExtension] with ExtensionIdProvider {
@@ -53,7 +53,7 @@ class InstanceCountingExtension extends Extension {
InstanceCountingExtension.createCount.incrementAndGet()
}
-// Dont't place inside ActorSystemSpec object, since it will not be garbage collected and reference to system remains
+// Don't place inside ActorSystemSpec object, since it will not be garbage collected and reference to system remains
class FailingTestExtension(val system: ExtendedActorSystem) extends Extension {
// create a named actor as a side effect of initializing this extension, relevant
// for the 'handle extensions that fail to initialize' test.
diff --git a/actor-tests/src/test/scala/org/apache/pekko/routing/BalancingSpec.scala b/actor-tests/src/test/scala/org/apache/pekko/routing/BalancingSpec.scala
index 3d77f6bfd2..b3068bed66 100644
--- a/actor-tests/src/test/scala/org/apache/pekko/routing/BalancingSpec.scala
+++ b/actor-tests/src/test/scala/org/apache/pekko/routing/BalancingSpec.scala
@@ -40,10 +40,10 @@ object BalancingSpec {
latch.countDown()
if (id == 1) {
if (!latch.isOpen) {
- log.debug("Waiting for all routees to receieve a message")
+ log.debug("Waiting for all routees to receive a message")
// wait for all routees to receive a message before processing
Await.result(latch, 1.minute)
- log.debug("All routees receieved a message, continuing")
+ log.debug("All routees received a message, continuing")
}
} else {
if (!startOthers.isCompleted) {
diff --git a/actor-tests/src/test/scala/org/apache/pekko/util/ByteStringInitializationSpec.scala b/actor-tests/src/test/scala/org/apache/pekko/util/ByteStringInitializationSpec.scala
index e96bc75639..b14b5e56f0 100644
--- a/actor-tests/src/test/scala/org/apache/pekko/util/ByteStringInitializationSpec.scala
+++ b/actor-tests/src/test/scala/org/apache/pekko/util/ByteStringInitializationSpec.scala
@@ -22,7 +22,7 @@ import org.scalatest.matchers.should.Matchers
import org.scalatest.wordspec.AnyWordSpec
class ByteStringInitializationSpec extends AnyWordSpec with Matchers {
- "ByteString intialization" should {
+ "ByteString initialization" should {
"not get confused by initializing CompactByteString before ByteString" in {
// a classloader that creates a new universe of classes for everything beneath akka
// that prevents that this test interacts with any tests
diff --git a/actor-typed/src/main/scala/org/apache/pekko/actor/typed/internal/adapter/ActorAdapter.scala b/actor-typed/src/main/scala/org/apache/pekko/actor/typed/internal/adapter/ActorAdapter.scala
index 9638149134..3800116a76 100644
--- a/actor-typed/src/main/scala/org/apache/pekko/actor/typed/internal/adapter/ActorAdapter.scala
+++ b/actor-typed/src/main/scala/org/apache/pekko/actor/typed/internal/adapter/ActorAdapter.scala
@@ -344,7 +344,7 @@ import pekko.util.OptionVal
stopBehavior: StoppedBehavior[T])
extends ExtensibleBehavior[T] {
override def receive(ctx: TypedActorContext[T], msg: T): Behavior[T] =
- throw new IllegalStateException("Stopping, should never receieve a message")
+ throw new IllegalStateException("Stopping, should never receive a message")
override def receiveSignal(ctx: TypedActorContext[T], msg: Signal): Behavior[T] = {
if (msg != PostStop)
throw new IllegalArgumentException(
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 26dae3a91a..ab523d3b4e 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
@@ -583,10 +583,10 @@ private class ShardingProducerControllerImpl[A: ClassTag](
private def createRequestNext(s: State[A]): RequestNext[A] = {
val entitiesWithDemand = s.out.valuesIterator.collect { case out if out.nextTo.nonEmpty => out.entityId }.toSet
- val bufferedForEntitesWithoutDemand = s.out.valuesIterator.collect {
+ val bufferedForEntitiesWithoutDemand = s.out.valuesIterator.collect {
case out if out.nextTo.isEmpty => out.entityId -> out.buffered.size
}.toMap
- RequestNext(msgAdapter, context.self, entitiesWithDemand, bufferedForEntitesWithoutDemand)
+ RequestNext(msgAdapter, context.self, entitiesWithDemand, bufferedForEntitiesWithoutDemand)
}
private def send(msg: A, outKey: OutKey, outSeqNr: OutSeqNr, nextTo: ProducerController.RequestNext[A]): Unit = {
diff --git a/cluster-sharding-typed/src/multi-jvm/scala/org/apache/pekko/cluster/sharding/ClusterShardingRememberEntitiesPerfSpec.scala b/cluster-sharding-typed/src/multi-jvm/scala/org/apache/pekko/cluster/sharding/ClusterShardingRememberEntitiesPerfSpec.scala
index d89b330ee5..5c520edd88 100644
--- a/cluster-sharding-typed/src/multi-jvm/scala/org/apache/pekko/cluster/sharding/ClusterShardingRememberEntitiesPerfSpec.scala
+++ b/cluster-sharding-typed/src/multi-jvm/scala/org/apache/pekko/cluster/sharding/ClusterShardingRememberEntitiesPerfSpec.scala
@@ -215,7 +215,7 @@ abstract class ClusterShardingRememberEntitiesPerfSpec
"test latency when starting new entity and sending a few messages to it and stopping" in {
val numberOfMessages = 800 * NrOfMessagesFactor
- // 160 entities, and an extra one for the intialization
+ // 160 entities, and an extra one for the initialization
// all but the first one are not removed
runBench("start, few messages, stop") { (iteration, region, histogram) =>
for (n <- 1 to numberOfMessages / 5; m <- 1 to 5) {
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 1cebbffc1b..1af3ca7d3a 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
@@ -95,7 +95,7 @@ object ShardCoordinator {
* of previously allocated shards. They will then be allocated to the `ShardRegion` with least number of
* previously allocated shards, i.e. new members in the cluster. The amount of shards to rebalance in each
* round can be limited to make it progress slower since rebalancing too many shards at the same time could
- * result in additional load on the system. For example, causing many Event Sourced entites to be started
+ * result in additional load on the system. For example, causing many Event Sourced entities to be started
* at the same time.
*
* It will not rebalance when there is already an ongoing rebalance in progress.
@@ -118,7 +118,7 @@ object ShardCoordinator {
* of previously allocated shards. They will then be allocated to the `ShardRegion` with least number of
* previously allocated shards, i.e. new members in the cluster. The amount of shards to rebalance in each
* round can be limited to make it progress slower since rebalancing too many shards at the same time could
- * result in additional load on the system. For example, causing many Event Sourced entites to be started
+ * result in additional load on the system. For example, causing many Event Sourced entities to be started
* at the same time.
*
* It will not rebalance when there is already an ongoing rebalance in progress.
diff --git a/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/internal/LeastShardAllocationStrategy.scala b/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/internal/LeastShardAllocationStrategy.scala
index 1f93b89023..c2d2a54df4 100644
--- a/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/internal/LeastShardAllocationStrategy.scala
+++ b/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/internal/LeastShardAllocationStrategy.scala
@@ -41,7 +41,7 @@ import pekko.cluster.sharding.internal.AbstractLeastShardAllocationStrategy.Shar
* of previously allocated shards. They will then be allocated to the `ShardRegion` with least number of
* previously allocated shards, i.e. new members in the cluster. The amount of shards to rebalance in each
* round can be limited to make it progress slower since rebalancing too many shards at the same time could
- * result in additional load on the system. For example, causing many Event Sourced entites to be started
+ * result in additional load on the system. For example, causing many Event Sourced entities to be started
* at the same time.
*
* It will not rebalance when there is already an ongoing rebalance in progress.
diff --git a/distributed-data/src/multi-jvm/scala/org/apache/pekko/cluster/ddata/ReplicatorSpec.scala b/distributed-data/src/multi-jvm/scala/org/apache/pekko/cluster/ddata/ReplicatorSpec.scala
index 7e0e52a191..aaba6a8533 100644
--- a/distributed-data/src/multi-jvm/scala/org/apache/pekko/cluster/ddata/ReplicatorSpec.scala
+++ b/distributed-data/src/multi-jvm/scala/org/apache/pekko/cluster/ddata/ReplicatorSpec.scala
@@ -455,7 +455,7 @@ class ReplicatorSpec extends MultiNodeSpec(ReplicatorSpec) with STMultiNodeSpec
enterBarrier("local-update-from-second")
runOn(first) {
- // ReadMajority should retrive the previous update from second, before applying the modification
+ // ReadMajority should retrieve the previous update from second, before applying the modification
val probe1 = TestProbe()
val probe2 = TestProbe()
replicator.tell(Get(KeyE, readMajority), probe2.ref)
diff --git a/docs/src/main/paradox/stream/operators/Source-or-Flow/collect.md b/docs/src/main/paradox/stream/operators/Source-or-Flow/collect.md
index 1418aa3694..c9206838bf 100644
--- a/docs/src/main/paradox/stream/operators/Source-or-Flow/collect.md
+++ b/docs/src/main/paradox/stream/operators/Source-or-Flow/collect.md
@@ -31,7 +31,7 @@ Java
From a stream of `Message` elements we would like to collect all elements of type `Ping` that have an `id != 0`,
-and then covert to `Pong` with same id.
+and then convert to `Pong` with same id.
Scala
: @@snip [Collect.scala](/docs/src/test/scala/docs/stream/operators/sourceorflow/Collect.scala) { #collect }
diff --git a/docs/src/main/paradox/stream/operators/Source-or-Flow/collectType.md b/docs/src/main/paradox/stream/operators/Source-or-Flow/collectType.md
index 796b9d2286..88c5a41ce1 100644
--- a/docs/src/main/paradox/stream/operators/Source-or-Flow/collectType.md
+++ b/docs/src/main/paradox/stream/operators/Source-or-Flow/collectType.md
@@ -27,7 +27,7 @@ Java
From a stream of `Message` elements we would like to collect all elements of type `Ping` that have an `id != 0`,
-and then covert to `Pong` with same id.
+and then convert to `Pong` with same id.
Scala
: @@snip [Collect.scala](/docs/src/test/scala/docs/stream/operators/sourceorflow/Collect.scala) { #collectType }
diff --git a/docs/src/main/paradox/stream/operators/Source-or-Flow/mapAsyncUnordered.md b/docs/src/main/paradox/stream/operators/Source-or-Flow/mapAsyncUnordered.md
index 507f5fd7a4..676a21fdf5 100644
--- a/docs/src/main/paradox/stream/operators/Source-or-Flow/mapAsyncUnordered.md
+++ b/docs/src/main/paradox/stream/operators/Source-or-Flow/mapAsyncUnordered.md
@@ -32,19 +32,19 @@ When running the stream above the logging output would look like:
```
[...]
-Processing event numner Event(27)...
+Processing event number Event(27)...
Completed processing 27
`mapAsyncUnordered` emitted event number: 27
-Processing event numner Event(28)...
+Processing event number Event(28)...
Completed processing 22
`mapAsyncUnordered` emitted event number: 22
-Processing event numner Event(29)...
+Processing event number Event(29)...
Completed processing 26
`mapAsyncUnordered` emitted event number: 26
-Processing event numner Event(30)...
+Processing event number Event(30)...
Completed processing 30
`mapAsyncUnordered` emitted event number: 30
-Processing event numner Event(31)...
+Processing event number Event(31)...
Completed processing 31
`mapAsyncUnordered` emitted event number: 31
[...]
diff --git a/docs/src/main/paradox/typed/cluster-sharding.md b/docs/src/main/paradox/typed/cluster-sharding.md
index abeb3e554d..ac7a98d599 100644
--- a/docs/src/main/paradox/typed/cluster-sharding.md
+++ b/docs/src/main/paradox/typed/cluster-sharding.md
@@ -183,7 +183,7 @@ The `LeastShardAllocationStrategy` picks shards for rebalancing from the `ShardR
of previously allocated shards. They will then be allocated to the `ShardRegion` with least number of
previously allocated shards, i.e. new members in the cluster. The amount of shards to rebalance in each
round can be limited to make it progress slower since rebalancing too many shards at the same time could
-result in additional load on the system. For example, causing many Event Sourced entites to be started
+result in additional load on the system. For example, causing many Event Sourced entities to be started
at the same time.
A new rebalance algorithm is included in Pekko. It can reach optimal balance in a few rebalance rounds
diff --git a/persistence-typed-tests/src/test/java/org/apache/pekko/persistence/typed/javadsl/EventSourcedBehaviorJavaDslTest.java b/persistence-typed-tests/src/test/java/org/apache/pekko/persistence/typed/javadsl/EventSourcedBehaviorJavaDslTest.java
index c8080e8946..4318192429 100644
--- a/persistence-typed-tests/src/test/java/org/apache/pekko/persistence/typed/javadsl/EventSourcedBehaviorJavaDslTest.java
+++ b/persistence-typed-tests/src/test/java/org/apache/pekko/persistence/typed/javadsl/EventSourcedBehaviorJavaDslTest.java
@@ -675,7 +675,7 @@ public class EventSourcedBehaviorJavaDslTest extends JUnitSuite {
.none()
.thenRun(
(String wrongType) -> {
- // wont happen
+ // won't happen
}))
.build();
}
diff --git a/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehavior.scala b/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehavior.scala
index 5563e8f084..0b4ba309de 100644
--- a/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehavior.scala
+++ b/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehavior.scala
@@ -59,7 +59,7 @@ object EventSourcedBehavior {
* Create a `Behavior` for a persistent actor.
*
* @param persistenceId stable unique identifier for the event sourced behavior
- * @param emptyState the intial state for the entity before any events have been processed
+ * @param emptyState the initial state for the entity before any events have been processed
* @param commandHandler map commands to effects e.g. persisting events, replying to commands
* @param eventHandler compute the new state given the current state when an event has been persisted
*/
diff --git a/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/state/scaladsl/DurableStateBehavior.scala b/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/state/scaladsl/DurableStateBehavior.scala
index b623f36632..86af20cf35 100644
--- a/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/state/scaladsl/DurableStateBehavior.scala
+++ b/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/state/scaladsl/DurableStateBehavior.scala
@@ -50,7 +50,7 @@ object DurableStateBehavior {
* Create a `Behavior` for a persistent actor with durable storage of its state.
*
* @param persistenceId stable unique identifier for the `DurableStateBehavior`
- * @param emptyState the intial state for the entity before any state has been stored
+ * @param emptyState the initial state for the entity before any state has been stored
* @param commandHandler map commands to effects e.g. persisting state, replying to commands
*/
def apply[Command, State](
diff --git a/remote/src/main/scala/org/apache/pekko/remote/artery/EnvelopeBufferPool.scala b/remote/src/main/scala/org/apache/pekko/remote/artery/EnvelopeBufferPool.scala
index 306ce5fbbd..7cd602715a 100644
--- a/remote/src/main/scala/org/apache/pekko/remote/artery/EnvelopeBufferPool.scala
+++ b/remote/src/main/scala/org/apache/pekko/remote/artery/EnvelopeBufferPool.scala
@@ -162,13 +162,13 @@ private[remote] sealed trait HeaderBuilder {
def setSenderActorRef(ref: ActorRef): Unit
/**
- * Retrive the compressed ActorRef by the compressionId carried by this header.
+ * Retrieve the compressed ActorRef by the compressionId carried by this header.
* Returns `None` if ActorRef was not compressed, and then the literal [[senderActorRefPath]] should be used.
*/
def senderActorRef(originUid: Long): OptionVal[ActorRef]
/**
- * Retrive the raw literal actor path, instead of using the compressed value.
+ * Retrieve the raw literal actor path, instead of using the compressed value.
* Returns `None` if ActorRef was compressed (!). To obtain the path in such case call [[senderActorRef]] and extract the path from it directly.
*/
def senderActorRefPath: OptionVal[String]
@@ -182,13 +182,13 @@ private[remote] sealed trait HeaderBuilder {
def setRecipientActorRef(ref: ActorRef): Unit
/**
- * Retrive the compressed ActorRef by the compressionId carried by this header.
+ * Retrieve the compressed ActorRef by the compressionId carried by this header.
* Returns `None` if ActorRef was not compressed, and then the literal [[recipientActorRefPath]] should be used.
*/
def recipientActorRef(originUid: Long): OptionVal[ActorRef]
/**
- * Retrive the raw literal actor path, instead of using the compressed value.
+ * Retrieve the raw literal actor path, instead of using the compressed value.
* Returns `None` if ActorRef was compressed (!). To obtain the path in such case call [[recipientActorRefPath]] and extract the path from it directly.
*/
def recipientActorRefPath: OptionVal[String]
diff --git a/remote/src/test/scala/org/apache/pekko/remote/serialization/MiscMessageSerializerSpec.scala b/remote/src/test/scala/org/apache/pekko/remote/serialization/MiscMessageSerializerSpec.scala
index f66de88a05..677371e8a6 100644
--- a/remote/src/test/scala/org/apache/pekko/remote/serialization/MiscMessageSerializerSpec.scala
+++ b/remote/src/test/scala/org/apache/pekko/remote/serialization/MiscMessageSerializerSpec.scala
@@ -194,7 +194,7 @@ class MiscMessageSerializerSpec extends PekkoSpec(MiscMessageSerializerSpec.test
classOf[MiscMessageSerializer])
}
- "serialize and deserialze ActorInitializationException" in {
+ "serialize and deserialize ActorInitializationException" in {
val aiex = ActorInitializationException(ref, "test", new TestException("err"))
val serializer = new MiscMessageSerializer(system.asInstanceOf[ExtendedActorSystem])
val deserialized = serializer
@@ -209,7 +209,7 @@ class MiscMessageSerializerSpec extends PekkoSpec(MiscMessageSerializerSpec.test
deserialized.getCause.getMessage should ===(aiex.getCause.getMessage)
}
- "serialize and deserialze ActorInitializationException if ref is null" in {
+ "serialize and deserialize ActorInitializationException if ref is null" in {
val aiex = ActorInitializationException(null, "test", new TestException("err"))
val serializer = new MiscMessageSerializer(system.asInstanceOf[ExtendedActorSystem])
val deserialized = serializer
@@ -224,7 +224,7 @@ class MiscMessageSerializerSpec extends PekkoSpec(MiscMessageSerializerSpec.test
deserialized.getCause.getMessage should ===(aiex.getCause.getMessage)
}
- "serialize and deserialze ActorInitializationException if cause is null" in {
+ "serialize and deserialize ActorInitializationException if cause is null" in {
val aiex = ActorInitializationException(ref, "test", null)
val serializer = new MiscMessageSerializer(system.asInstanceOf[ExtendedActorSystem])
val deserialized = serializer
@@ -238,7 +238,7 @@ class MiscMessageSerializerSpec extends PekkoSpec(MiscMessageSerializerSpec.test
deserialized.getCause should be(null)
}
- "serialize and deserialze ActorInitializationException when cause is not serializable" in {
+ "serialize and deserialize ActorInitializationException when cause is not serializable" in {
val aiex = ActorInitializationException(ref, "test", new IllegalStateException("err"))
val serializer = new MiscMessageSerializer(system.asInstanceOf[ExtendedActorSystem])
val deserialized = serializer
@@ -252,7 +252,7 @@ class MiscMessageSerializerSpec extends PekkoSpec(MiscMessageSerializerSpec.test
}
}
- "serialize and deserialze ThrowableNotSerializableException" in {
+ "serialize and deserialize ThrowableNotSerializableException" in {
val notExc = new ThrowableNotSerializableException(
"test",
classOf[IllegalStateException].getName,
@@ -267,7 +267,7 @@ class MiscMessageSerializerSpec extends PekkoSpec(MiscMessageSerializerSpec.test
deserialized.getCause should ===(null)
}
- "serialize and deserialze Status.Failure with unknown exception" in {
+ "serialize and deserialize Status.Failure with unknown exception" in {
val statusFailure = Status.Failure(new IllegalStateException("test"))
val serializer = new MiscMessageSerializer(system.asInstanceOf[ExtendedActorSystem])
val deserialized = serializer
diff --git a/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowCollectFirstSpec.scala b/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowCollectFirstSpec.scala
index f38a905b13..84a7bcf1ae 100644
--- a/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowCollectFirstSpec.scala
+++ b/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowCollectFirstSpec.scala
@@ -40,7 +40,7 @@ class FlowCollectFirstSpec extends StreamSpec with ScriptedTest {
.expectComplete()
}
- "complete with buffer even no explict request" in {
+ "complete with buffer even no explicit request" in {
Source(List(2, 4, 6))
.collectFirst {
case elem if elem % 2 != 0 => elem
diff --git a/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowCollectWhileSpec.scala b/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowCollectWhileSpec.scala
index 7647016cff..ebb85fc667 100644
--- a/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowCollectWhileSpec.scala
+++ b/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowCollectWhileSpec.scala
@@ -40,7 +40,7 @@ class FlowCollectWhileSpec extends StreamSpec with ScriptedTest {
.expectComplete()
}
- "complete with buffer even no explict request" in {
+ "complete with buffer even no explicit request" in {
Source(List(2, 3, 5))
.collectWhile {
case elem if elem % 2 != 0 => elem
diff --git a/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/SinkSpec.scala b/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/SinkSpec.scala
index 481c2a2cee..0e900fc5d5 100644
--- a/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/SinkSpec.scala
+++ b/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/SinkSpec.scala
@@ -356,7 +356,7 @@ class SinkSpec extends StreamSpec with DefaultTimeout with ScalaFutures {
"The forall sink" must {
- "completes with `ture` when all elements match" in {
+ "completes with `true` when all elements match" in {
Source(1 to 4)
.runWith(Sink.forall(_ > 0))
.futureValue shouldBe true
@@ -397,7 +397,7 @@ class SinkSpec extends StreamSpec with DefaultTimeout with ScalaFutures {
"The none sink" must {
- "completes with `ture` when all elements not match" in {
+ "completes with `true` when all elements not match" in {
Source(1 to 4)
.runWith(Sink.none(_ < 0))
.futureValue shouldBe true
diff --git a/stream/src/main/scala/org/apache/pekko/stream/QueueOfferResult.scala b/stream/src/main/scala/org/apache/pekko/stream/QueueOfferResult.scala
index 0b4e70b5e5..ac114f3f59 100644
--- a/stream/src/main/scala/org/apache/pekko/stream/QueueOfferResult.scala
+++ b/stream/src/main/scala/org/apache/pekko/stream/QueueOfferResult.scala
@@ -22,7 +22,7 @@ import org.apache.pekko.annotation.DoNotInherit
sealed abstract class QueueOfferResult {
/**
- * Return ture if the element was already enqueued, otherwise false.
+ * Return true if the element was already enqueued, otherwise false.
*/
def isEnqueued: Boolean
}
diff --git a/stream/src/main/scala/org/apache/pekko/stream/javadsl/Flow.scala b/stream/src/main/scala/org/apache/pekko/stream/javadsl/Flow.scala
index 13b1c75826..117df4e416 100755
--- a/stream/src/main/scala/org/apache/pekko/stream/javadsl/Flow.scala
+++ b/stream/src/main/scala/org/apache/pekko/stream/javadsl/Flow.scala
@@ -2183,7 +2183,7 @@ final class Flow[In, Out, Mat](delegate: scaladsl.Flow[In, Out, Mat]) extends Gr
*
* '''Backpressures when''' downstream backpressures
*
- * '''Completes when''' upstream completes or failed with predicate return ture
+ * '''Completes when''' upstream completes or failed with predicate return true
*
* '''Cancels when''' downstream cancels
* @since 1.1.0
diff --git a/stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala b/stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala
index 05a63b799c..e7806e55d8 100755
--- a/stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala
+++ b/stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala
@@ -2402,7 +2402,7 @@ final class Source[Out, Mat](delegate: scaladsl.Source[Out, Mat]) extends Graph[
*
* '''Backpressures when''' downstream backpressures
*
- * '''Completes when''' upstream completes or failed with predicate return ture
+ * '''Completes when''' upstream completes or failed with predicate return true
*
* '''Cancels when''' downstream cancels
* @since 1.1.0
diff --git a/stream/src/main/scala/org/apache/pekko/stream/javadsl/SubFlow.scala b/stream/src/main/scala/org/apache/pekko/stream/javadsl/SubFlow.scala
index 06c57b498a..4f6652310e 100755
--- a/stream/src/main/scala/org/apache/pekko/stream/javadsl/SubFlow.scala
+++ b/stream/src/main/scala/org/apache/pekko/stream/javadsl/SubFlow.scala
@@ -1468,7 +1468,7 @@ final class SubFlow[In, Out, Mat](
*
* '''Backpressures when''' downstream backpressures
*
- * '''Completes when''' upstream completes or failed with predicate return ture
+ * '''Completes when''' upstream completes or failed with predicate return true
*
* '''Cancels when''' downstream cancels
* @since 1.1.0
diff --git a/stream/src/main/scala/org/apache/pekko/stream/javadsl/SubSource.scala b/stream/src/main/scala/org/apache/pekko/stream/javadsl/SubSource.scala
index 0509cdbb6e..d41f4c6465 100755
--- a/stream/src/main/scala/org/apache/pekko/stream/javadsl/SubSource.scala
+++ b/stream/src/main/scala/org/apache/pekko/stream/javadsl/SubSource.scala
@@ -1437,7 +1437,7 @@ final class SubSource[Out, Mat](
*
* '''Backpressures when''' downstream backpressures
*
- * '''Completes when''' upstream completes or failed with predicate return ture
+ * '''Completes when''' upstream completes or failed with predicate return true
*
* '''Cancels when''' downstream cancels
* @since 1.1.0
diff --git a/stream/src/main/scala/org/apache/pekko/stream/scaladsl/Framing.scala b/stream/src/main/scala/org/apache/pekko/stream/scaladsl/Framing.scala
index 18ac5f33d6..c3becf8ada 100644
--- a/stream/src/main/scala/org/apache/pekko/stream/scaladsl/Framing.scala
+++ b/stream/src/main/scala/org/apache/pekko/stream/scaladsl/Framing.scala
@@ -262,7 +262,7 @@ object Framing {
// Next possible position for the delimiter
val possibleMatchPos = buffer.indexOf(firstSeparatorByte, from = nextPossibleMatch)
- // Retrive previous position
+ // Retrieve previous position
val previous = indices.lastOption match {
case OptionVal.Some((_, i)) => i + separatorBytes.size
case _ => 0
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org