Skip to content

Commit

Permalink
improve a/an after get (#566)
Browse files Browse the repository at this point in the history
  • Loading branch information
dongxuwang authored Aug 12, 2023
1 parent 2ad6c6c commit 80e4e80
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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)
}

Expand Down Expand Up @@ -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",
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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(_) =>
Expand Down

0 comments on commit 80e4e80

Please sign in to comment.