raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Fix stream detached exception variable naming (#27711)

Browse source
This commit is contained in:
Mahmut Bulut 2019-09-16 09:55:06 +02:00 • committed by Arnout Engelen
parent c30aacf991
commit bc590af56f
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-stream/src/main/scala/akka/stream/stage/GraphStage.scala
View file

@ -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")
/**