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

Don't use GraphStage toString when materializing Source.fromPublisher, #30022

Browse source 
* Fixes performance regression in Akka 2.6.11/2.6.12
This commit is contained in:
Patrik Nordwall 2021-02-12 09:34:18 +01:00
parent 278a36d036
commit f5625dc64d
1 changed files with 1 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

3
akka-stream/src/main/scala/akka/stream/impl/PhasedFusingActorMaterializer.scala
View file

@ -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)