commit | dae1160e3c908225968c99101403116c6bcd82f0 | [log] [tgz] |
---|---|---|
author | Jordan Halterman <jordan@opennetworking.org> | Tue Jul 03 00:00:47 2018 -0700 |
committer | Charles Chan <charles@opennetworking.org> | Mon Jul 09 22:04:41 2018 +0000 |
tree | da8cdd0ea30566e220d5df6c704402b711a666b4 | |
parent | 68faf956fb18d4d47c3e0a60eb636a921aa2bceb [diff] [blame] |
Implement lazy iterators/streams for ConsistentMap Change-Id: Id643726441c99186667c104cfdd1dab95b06cf87
diff --git a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/DelegatingAsyncConsistentTreeMap.java b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/DelegatingAsyncConsistentTreeMap.java index 2bee5eb..b3a1f95 100644 --- a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/DelegatingAsyncConsistentTreeMap.java +++ b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/DelegatingAsyncConsistentTreeMap.java
@@ -30,6 +30,7 @@ import org.onosproject.store.primitives.MapUpdate; import org.onosproject.store.primitives.TransactionId; import org.onosproject.store.service.AsyncConsistentTreeMap; +import org.onosproject.store.service.AsyncIterator; import org.onosproject.store.service.MapEventListener; import org.onosproject.store.service.TransactionLog; import org.onosproject.store.service.Version; @@ -239,6 +240,11 @@ } @Override + public CompletableFuture<AsyncIterator<Map.Entry<String, Versioned<V>>>> iterator() { + return delegateMap.iterator(); + } + + @Override public CompletableFuture<Void> addListener( MapEventListener<String, V> listener, Executor executor) { return delegateMap.addListener(listener, executor);