peter-ematiq opened a new issue, #1426:
URL: https://github.com/apache/pekko/issues/1426
Hi today I've found a bug regarding name attribute overriding in
`SourceQueueWithComplete`.
If I create a `Source.queue` like this `Source.queue[Int](10,
OverflowStrategy.dropHead)`
It calls following method:
```
def queue[T](
bufferSize: Int,
overflowStrategy: OverflowStrategy,
maxConcurrentOffers: Int): Source[T, SourceQueueWithComplete[T]] =
Source.fromGraph(new QueueSource(bufferSize, overflowStrategy,
maxConcurrentOffers).withAttributes(DefaultAttributes.queueSource))
```
Here it calls `withAttributes(DefaultAttributes.queueSource)` which
overrides any given name to the graph component.
From my observation, I assume that the strategy of name attribute overriding
is incorrect. Because the very first attribute is used and the rest is
discarded.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
