From 392a05c93361acd9ab1eeb54c36ccf1e4fd78807 Mon Sep 17 00:00:00 2001 From: PJ Fanning Date: Thu, 8 Aug 2024 13:51:38 +0100 Subject: [PATCH] fix code comment with 'aquired' typo (#1429) --- .../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 715e0e90617..98a494de53e 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