From bc590af56f39cff358d7a67d28f01e98f05741a8 Mon Sep 17 00:00:00 2001
From: Mahmut Bulut <vertexclique@gmail.com>
Date: Mon, 16 Sep 2019 09:55:06 +0200
Subject: [PATCH] Fix stream detached exception variable naming (#27711)

---
 .../src/main/scala/akka/stream/stage/GraphStage.scala       | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/akka-stream/src/main/scala/akka/stream/stage/GraphStage.scala b/akka-stream/src/main/scala/akka/stream/stage/GraphStage.scala
index 6c28fe9bef..79b76b2818 100644
--- a/akka-stream/src/main/scala/akka/stream/stage/GraphStage.scala
+++ b/akka-stream/src/main/scala/akka/stream/stage/GraphStage.scala
@@ -1186,7 +1186,7 @@ abstract class GraphStageLogic private[stream] (val inCount: Int, val outCount:
         invokeWithPromise(event, promise)
         promise.future
       } else
-        Future.failed(streamDetatchedException)
+        Future.failed(streamDetachedException)
     }
 
     //external call
@@ -1301,7 +1301,7 @@ abstract class GraphStageLogic private[stream] (val inCount: Int, val outCount:
     // and fail current outstanding invokeWithFeedback promises
     val inProgress = asyncCallbacksInProgress.getAndSet(null)
     if (inProgress.nonEmpty) {
-      val exception = streamDetatchedException
+      val exception = streamDetachedException
       inProgress.foreach(_.tryFailure(exception))
     }
   }
@@ -1330,7 +1330,7 @@ abstract class GraphStageLogic private[stream] (val inCount: Int, val outCount:
     }
   }
 
-  private def streamDetatchedException =
+  private def streamDetachedException =
     new StreamDetachedException(s"Stage with GraphStageLogic ${this} stopped before async invocation was processed")
 
   /**