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/incubator-pekko.git
The following commit(s) were added to refs/heads/main by this push:
new 80e4e800c8 improve a/an after get (#566)
80e4e800c8 is described below
commit 80e4e800c8b631b49ae6c1d9e9e9612be3228de3
Author: Dongxu Wang <[email protected]>
AuthorDate: Sat Aug 12 22:59:30 2023 +0800
improve a/an after get (#566)
---
.../src/test/scala/org/apache/pekko/actor/ActorMailboxSpec.scala | 4 ++--
.../scala/org/apache/pekko/stream/impl/streamref/SourceRefImpl.scala | 2 +-
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git
a/actor-tests/src/test/scala/org/apache/pekko/actor/ActorMailboxSpec.scala
b/actor-tests/src/test/scala/org/apache/pekko/actor/ActorMailboxSpec.scala
index 9ed18eb451..99222249ff 100644
--- a/actor-tests/src/test/scala/org/apache/pekko/actor/ActorMailboxSpec.scala
+++ b/actor-tests/src/test/scala/org/apache/pekko/actor/ActorMailboxSpec.scala
@@ -263,7 +263,7 @@ class ActorMailboxSpec(conf: Config) extends
PekkoSpec(conf) with DefaultTimeout
UnboundedDeqMailboxTypes)
}
- "get an bounded message queue when it's only configured with
RequiresMailbox" in {
+ "get a bounded message queue when it's only configured with
RequiresMailbox" in {
checkMailboxQueue(Props[BoundedQueueReportingActor](),
"default-override-from-trait", BoundedMailboxTypes)
}
@@ -299,7 +299,7 @@ class ActorMailboxSpec(conf: Config) extends
PekkoSpec(conf) with DefaultTimeout
UnboundedControlAwareMailboxTypes)
}
- "get an bounded control aware message queue when it's only configured with
RequiresMailbox" in {
+ "get a bounded control aware message queue when it's only configured with
RequiresMailbox" in {
checkMailboxQueue(
Props[BoundedControlAwareQueueReportingActor](),
"default-override-from-trait-bounded-control-aware",
diff --git
a/stream/src/main/scala/org/apache/pekko/stream/impl/streamref/SourceRefImpl.scala
b/stream/src/main/scala/org/apache/pekko/stream/impl/streamref/SourceRefImpl.scala
index 442034d403..715e0e9061 100644
---
a/stream/src/main/scala/org/apache/pekko/stream/impl/streamref/SourceRefImpl.scala
+++
b/stream/src/main/scala/org/apache/pekko/stream/impl/streamref/SourceRefImpl.scala
@@ -419,7 +419,7 @@ private[stream] final class SourceRefStageImpl[Out](val
initialPartnerRef: Optio
scheduleOnce(TerminationDeadlineTimerKey,
finalTerminationSignalDeadline)
case AwaitingSubscription(ref) =>
- // we didn't get an a first demand yet but have access to the
partner - try a cancellation dance
+ // we didn't get a first demand yet but have access to the partner
- try a cancellation dance
triggerCancellationExchange(ref, cause)
case UpstreamCompleted(_) =>
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
