FIR invoke consumer: do not process last data twice

2019-12-24 18:38:32 +03:00
parent 933bdc98e5
commit 9a514dfdd9
1 changed files with 2 additions and 1 deletions
@@ -143,7 +143,8 @@ class AccumulatingTowerDataConsumer(

    fun addConsumer(consumer: TowerDataConsumer): ProcessorAction {
        additionalConsumers += consumer
-        for ((kind, level, group) in accumulatedTowerData) {
+        if (accumulatedTowerData.isEmpty()) return ProcessorAction.NEXT
+        for ((kind, level, group) in accumulatedTowerData.asSequence().take(accumulatedTowerData.size - 1)) {
            if (consumer.consume(kind, level, group).stop()) {
                return ProcessorAction.STOP
            }