FIR invoke consumer: minor rename
This commit is contained in:
+1
-1
@@ -109,7 +109,7 @@ class InvokeReceiverCandidateCollector(
|
|||||||
invokeCallInfo.typeProvider
|
invokeCallInfo.typeProvider
|
||||||
)
|
)
|
||||||
|
|
||||||
invokeConsumer.addConsumer(
|
invokeConsumer.addConsumerAndProcessAccumulatedData(
|
||||||
createSimpleFunctionConsumer(
|
createSimpleFunctionConsumer(
|
||||||
session, OperatorNameConventions.INVOKE,
|
session, OperatorNameConventions.INVOKE,
|
||||||
boundInvokeCallInfo, towerResolver.components, towerResolver.collector
|
boundInvokeCallInfo, towerResolver.components, towerResolver.collector
|
||||||
|
|||||||
+1
-1
@@ -141,7 +141,7 @@ class AccumulatingTowerDataConsumer(
|
|||||||
return if (empty) ProcessorAction.NONE else ProcessorAction.NEXT
|
return if (empty) ProcessorAction.NONE else ProcessorAction.NEXT
|
||||||
}
|
}
|
||||||
|
|
||||||
fun addConsumer(consumer: TowerDataConsumer): ProcessorAction {
|
fun addConsumerAndProcessAccumulatedData(consumer: TowerDataConsumer): ProcessorAction {
|
||||||
additionalConsumers += consumer
|
additionalConsumers += consumer
|
||||||
if (accumulatedTowerData.isEmpty()) return ProcessorAction.NEXT
|
if (accumulatedTowerData.isEmpty()) return ProcessorAction.NEXT
|
||||||
for ((kind, level, group) in accumulatedTowerData.asSequence().take(accumulatedTowerData.size - 1)) {
|
for ((kind, level, group) in accumulatedTowerData.asSequence().take(accumulatedTowerData.size - 1)) {
|
||||||
|
|||||||
Reference in New Issue
Block a user