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

Merge pull request #30023 from akka/wip-30022-fromPublisher-patriknw

Browse source 
Don't use GraphStage toString when materializing Source.fromPublisher, #30022
This commit is contained in:
Patrik Nordwall 2021-02-15 14:38:11 +01:00 • committed by GitHub
commit 44fae64bd5
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
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)