Added DistributedPrimitive interface
Added AsyncDistributedSet that provides async set operations
Change-Id: I83494075a7973694ea6b7445ff4799b7a1a50641
diff --git a/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/DefaultDistributedSetBuilder.java b/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/DefaultDistributedSetBuilder.java
index f7957f3..92e3e9a 100644
--- a/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/DefaultDistributedSetBuilder.java
+++ b/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/DefaultDistributedSetBuilder.java
@@ -16,6 +16,7 @@
package org.onosproject.store.consistent.impl;
import org.onosproject.core.ApplicationId;
+import org.onosproject.store.service.AsyncDistributedSet;
import org.onosproject.store.service.ConsistentMapBuilder;
import org.onosproject.store.service.DistributedSet;
import org.onosproject.store.service.Serializer;
@@ -88,6 +89,11 @@
@Override
public DistributedSet<E> build() {
- return new DefaultDistributedSet<E>(name, metering, mapBuilder.build());
+ return new DefaultDistributedSet<E>(buildAsyncSet());
+ }
+
+ @Override
+ public AsyncDistributedSet<E> buildAsyncSet() {
+ return new DefaultAsyncDistributedSet<E>(mapBuilder.buildAsyncMap(), name, metering);
}
}