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

=str Avoid boxing Attributes in java Optional (#25456)

Browse source
This commit is contained in:
Andrea Peruffo 2018-08-20 16:43:46 +02:00 • committed by Konrad `ktoso` Malawski
parent 61f844471b
commit fddc198178
5 changed files with 5 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-stream/src/main/scala/akka/stream/impl/Sinks.scala
View file

@ -333,7 +333,7 @@ import scala.util.{ Failure, Success, Try }
val stageLogic = new GraphStageLogic(shape) with InHandler with SinkQueueWithCancel[T] {
type Received[E] = Try[Option[E]]
val maxBuffer = inheritedAttributes.getAttribute(classOf[InputBuffer], InputBuffer(16, 16)).max
val maxBuffer = inheritedAttributes.get[InputBuffer](InputBuffer(16, 16)).max
require(maxBuffer > 0, "Buffer size must be greater than 0")
var buffer: Buffer[Received[T]] = _