New API for specifying an executor when registering a map listener
Change-Id: I1fc92e0a3da576d88d5ece4a666af8ad1c1fb9d8
diff --git a/core/api/src/main/java/org/onosproject/store/primitives/DefaultConsistentTreeMap.java b/core/api/src/main/java/org/onosproject/store/primitives/DefaultConsistentTreeMap.java
index 745202c..46c458b 100644
--- a/core/api/src/main/java/org/onosproject/store/primitives/DefaultConsistentTreeMap.java
+++ b/core/api/src/main/java/org/onosproject/store/primitives/DefaultConsistentTreeMap.java
@@ -17,6 +17,7 @@
package org.onosproject.store.primitives;
import com.google.common.base.Throwables;
+
import org.onosproject.store.service.ConsistentMapException;
import org.onosproject.store.service.AsyncConsistentTreeMap;
import org.onosproject.store.service.MapEventListener;
@@ -30,6 +31,7 @@
import java.util.Set;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
+import java.util.concurrent.Executor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
import java.util.function.BiFunction;
@@ -258,8 +260,8 @@
}
@Override
- public void addListener(MapEventListener<K, V> listener) {
- complete(treeMap.addListener(listener));
+ public void addListener(MapEventListener<K, V> listener, Executor executor) {
+ complete(treeMap.addListener(listener, executor));
}
@Override