bug fix: type mismatch in mock Database
Change-Id: I529a76207e048f2a53ff66f17cd7a6b7bfa22797
Showing
1 changed file
with
4 additions
and
1 deletions
... | @@ -41,6 +41,8 @@ import org.onosproject.store.service.Versioned; | ... | @@ -41,6 +41,8 @@ import org.onosproject.store.service.Versioned; |
41 | import com.google.common.base.MoreObjects; | 41 | import com.google.common.base.MoreObjects; |
42 | import com.google.common.collect.ImmutableMap; | 42 | import com.google.common.collect.ImmutableMap; |
43 | import com.google.common.collect.ImmutableSet; | 43 | import com.google.common.collect.ImmutableSet; |
44 | +import com.google.common.collect.Maps; | ||
45 | + | ||
44 | import net.kuujo.copycat.Task; | 46 | import net.kuujo.copycat.Task; |
45 | import net.kuujo.copycat.cluster.Cluster; | 47 | import net.kuujo.copycat.cluster.Cluster; |
46 | import net.kuujo.copycat.resource.ResourceState; | 48 | import net.kuujo.copycat.resource.ResourceState; |
... | @@ -185,7 +187,8 @@ public class DefaultAsyncConsistentMapTest { | ... | @@ -185,7 +187,8 @@ public class DefaultAsyncConsistentMapTest { |
185 | @Override | 187 | @Override |
186 | public CompletableFuture<Boolean> mapContainsValue(String mapName, | 188 | public CompletableFuture<Boolean> mapContainsValue(String mapName, |
187 | byte[] value) { | 189 | byte[] value) { |
188 | - return CompletableFuture.completedFuture(map.containsValue(value)); | 190 | + return CompletableFuture.completedFuture(Maps.transformValues(map, Versioned::value) |
191 | + .containsValue(value)); | ||
189 | } | 192 | } |
190 | 193 | ||
191 | @Override | 194 | @Override | ... | ... |
-
Please register or login to post a comment