From f5625dc64dd2eceea33ec0a6c85a4d22d47d6daf Mon Sep 17 00:00:00 2001 From: Patrik Nordwall Date: Fri, 12 Feb 2021 09:34:18 +0100 Subject: [PATCH] Don't use GraphStage toString when materializing Source.fromPublisher, #30022 * Fixes performance regression in Akka 2.6.11/2.6.12 --- .../scala/akka/stream/impl/PhasedFusingActorMaterializer.scala | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/akka-stream/src/main/scala/akka/stream/impl/PhasedFusingActorMaterializer.scala b/akka-stream/src/main/scala/akka/stream/impl/PhasedFusingActorMaterializer.scala index 21f8800180..074e00a88e 100644 --- a/akka-stream/src/main/scala/akka/stream/impl/PhasedFusingActorMaterializer.scala +++ b/akka-stream/src/main/scala/akka/stream/impl/PhasedFusingActorMaterializer.scala @@ -769,10 +769,9 @@ private final case class SavedIslandData( override def takePublisher(slot: Int, publisher: Publisher[Any]): Unit = { val connection = conn(slot) - // TODO: proper input port debug string (currently prints the stage) val bufferSize = connection.inOwner.attributes.mandatoryAttribute[InputBuffer].max val boundary = - new BatchingActorInputBoundary(bufferSize, shell, publisher, connection.inOwner.toString) + new BatchingActorInputBoundary(bufferSize, shell, publisher, "publisher.in") logics.add(boundary) boundary.stageId = logics.size() - 1 boundary.attributes = connection.inOwner.attributes.and(DefaultAttributes.inputBoundary)