From 80e4e800c8b631b49ae6c1d9e9e9612be3228de3 Mon Sep 17 00:00:00 2001 From: Dongxu Wang Date: Sat, 12 Aug 2023 22:59:30 +0800 Subject: [PATCH] improve a/an after get (#566) --- .../test/scala/org/apache/pekko/actor/ActorMailboxSpec.scala | 4 ++-- .../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(_) =>