diff --git a/test/unit/voldemort/client/AdminServiceBasicTest.java b/test/unit/voldemort/client/AdminServiceBasicTest.java index 504cd80fe7..1cabc71654 100644 --- a/test/unit/voldemort/client/AdminServiceBasicTest.java +++ b/test/unit/voldemort/client/AdminServiceBasicTest.java @@ -637,34 +637,24 @@ protected Pair> computeNext() { @Test public void testUpdateSlops() { - final List entrySet = ServerTestUtils.createRandomSlops(0, - 10000, - testStoreName, - "users", - "test-replication-persistent", - "test-readrepair-memory", - "test-consistent", - "test-consistent-with-pref-list"); - - Iterator> slopIterator = new AbstractIterator>() { - - final Iterator entrySetItr = entrySet.iterator(); - - @Override - protected Versioned computeNext() { - while(entrySetItr.hasNext()) { - return Versioned.value(entrySetItr.next()); - } - return endOfData(); - } - }; - + final List> entrySet = ServerTestUtils.createRandomSlops(0, + 10000, + testStoreName, + "users", + "test-replication-persistent", + "test-readrepair-memory", + "test-consistent", + "test-consistent-with-pref-list"); + + Iterator> slopIterator = entrySet.iterator(); getAdminClient().updateSlopEntries(0, slopIterator); // check updated values - Iterator entrysetItr = entrySet.iterator(); + Iterator> entrysetItr = entrySet.iterator(); + while(entrysetItr.hasNext()) { - Slop nextSlop = entrysetItr.next(); + Versioned versioned = entrysetItr.next(); + Slop nextSlop = versioned.getValue(); Store store = getStore(0, nextSlop.getStoreName()); if(nextSlop.getOperation().equals(Slop.Operation.PUT)) {