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

=str Make decider a lazy val.

Browse source
This commit is contained in:
He-Pin 2023-09-03 20:40:38 +08:00 • committed by kerr
parent ac14251912
commit cdfcc56e2f
1 changed files with 2 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

5
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/Ops.scala
View file

@ -664,7 +664,7 @@ private[stream] object Collect {
def createLogic(inheritedAttributes: Attributes): GraphStageLogic = def createLogic(inheritedAttributes: Attributes): GraphStageLogic =
new GraphStageLogic(shape) with InHandler with OutHandler { new GraphStageLogic(shape) with InHandler with OutHandler {
val decider = inheritedAttributes.mandatoryAttribute[SupervisionStrategy].decider lazy val decider = inheritedAttributes.mandatoryAttribute[SupervisionStrategy].decider
private var aggregator: Out = zero private var aggregator: Out = zero
private var aggregating: Future[Out] = Future.successful(aggregator) private var aggregating: Future[Out] = Future.successful(aggregator)
@ -1402,8 +1402,7 @@ private[stream] object Collect {
new GraphStageLogic(shape) with InHandler with OutHandler { new GraphStageLogic(shape) with InHandler with OutHandler {
override def toString = s"MapAsyncUnordered.Logic(inFlight=$inFlight, buffer=$buffer)" override def toString = s"MapAsyncUnordered.Logic(inFlight=$inFlight, buffer=$buffer)"
private val decider = private lazy val decider = inheritedAttributes.mandatoryAttribute[SupervisionStrategy].decider
inheritedAttributes.mandatoryAttribute[SupervisionStrategy].decider
private var inFlight = 0 private var inFlight = 0
private var buffer: BufferImpl[Out] = _ private var buffer: BufferImpl[Out] = _