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 e316968566..d9b86c22cb 100644 --- a/akka-stream/src/main/scala/akka/stream/stage/GraphStage.scala +++ b/akka-stream/src/main/scala/akka/stream/stage/GraphStage.scala @@ -1583,6 +1583,9 @@ abstract class GraphStageLogic private[stream] (val inCount: Int, val outCount: override def toString = s"SubSourceOutlet($name)" } + override def toString: String = + attributes.get[Attributes.Name].map(attr => s"${getClass.toString}-${attr.n}").getOrElse(getClass.toString) + } /**