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 392a05c933 fix code comment with 'aquired' typo (#1429)
392a05c933 is described below
commit 392a05c93361acd9ab1eeb54c36ccf1e4fd78807
Author: PJ Fanning <[email protected]>
AuthorDate: Thu Aug 8 13:51:38 2024 +0100
fix code comment with 'aquired' typo (#1429)
---
.../scala/org/apache/pekko/stream/impl/streamref/SourceRefImpl.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 715e0e9061..98a494de53 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
@@ -85,7 +85,7 @@ private[stream] final case class
SourceRefImpl[T](initialPartnerRef: ActorRef) e
private case object AwaitingPartner extends State
// we're the "remote" for an already active Source on the other side (the
"origin")
private case class AwaitingSubscription(partner: ActorRef) extends
WeKnowPartner
- // subscription aquired and up and running
+ // subscription acquired and up and running
private final case class Running(partner: ActorRef) extends WeKnowPartner
// downstream cancelled or failed, waiting for remote upstream to ack
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
