Change the return type of IntentAccumulator.reduce()
Change-Id: I31b57537c800e1599f19e4c0a4156db9df0406af
diff --git a/core/net/src/main/java/org/onosproject/net/intent/impl/IntentAccumulator.java b/core/net/src/main/java/org/onosproject/net/intent/impl/IntentAccumulator.java
index 12369cc..2a3e68d 100644
--- a/core/net/src/main/java/org/onosproject/net/intent/impl/IntentAccumulator.java
+++ b/core/net/src/main/java/org/onosproject/net/intent/impl/IntentAccumulator.java
@@ -20,6 +20,7 @@
import org.onosproject.net.intent.IntentBatchDelegate;
import org.onosproject.net.intent.IntentData;
+import java.util.Collection;
import java.util.List;
import java.util.Map;
import java.util.Timer;
@@ -50,18 +51,17 @@
@Override
public void processEvents(List<IntentData> ops) {
- Map<String, IntentData> opMap = reduce(ops);
- delegate.execute(opMap.values());
+ delegate.execute(reduce(ops));
// FIXME kick off the work
//for (IntentData data : opMap.values()) {}
}
- private Map<String, IntentData> reduce(List<IntentData> ops) {
+ private Collection<IntentData> reduce(List<IntentData> ops) {
Map<String, IntentData> map = Maps.newHashMap();
for (IntentData op : ops) {
map.put(op.key(), op);
}
//TODO check the version... or maybe store will handle this.
- return map;
+ return map.values();
}
}