fix code comment with 'aquired' typo (#1429)

apache · Aug 8, 2024 · 392a05c · 392a05c
1 parent 338374c
commit 392a05c
Showing 1 changed file with 1 addition and 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
@@ -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