FIX: getOperationStatus method in asyncCollectionPipedInsert/Update.

Author: brido4125

src/main/java/net/spy/memcached/ArcusClient.java

@@ -952,8 +952,8 @@ <T> CollectionFuture<Map<Integer, CollectionOperationStatus>> asyncCollectionPip
 
     final CountDownLatch latch = new CountDownLatch(updateList.size());
 
-    final List<OperationStatus> mergedOperationStatus = Collections
-            .synchronizedList(new ArrayList<OperationStatus>(updateList.size()));
+    final List<CollectionOperationStatus> mergedOperationStatus = Collections
+            .synchronizedList(new ArrayList<CollectionOperationStatus>(updateList.size()));
 
     final Map<Integer, CollectionOperationStatus> mergedResult =
         new ConcurrentHashMap<Integer, CollectionOperationStatus>();
@@ -1058,12 +1058,12 @@ public Map<Integer, CollectionOperationStatus> get(long duration,
 
       @Override
       public CollectionOperationStatus getOperationStatus() {
-        for (OperationStatus status : mergedOperationStatus) {
+        for (CollectionOperationStatus status : mergedOperationStatus) {
           if (!status.isSuccess()) {
-            return new CollectionOperationStatus(status);
+            return status;
           }
         }
-        return new CollectionOperationStatus(true, "END", CollectionResponse.END);
+        return mergedOperationStatus.get(0);
       }
 
       @Override
@@ -3907,8 +3907,8 @@ <T> CollectionFuture<Map<Integer, CollectionOperationStatus>> asyncCollectionPip
 
     final CountDownLatch latch = new CountDownLatch(insertList.size());
 
-    final List<OperationStatus> mergedOperationStatus = Collections
-            .synchronizedList(new ArrayList<OperationStatus>(insertList.size()));
+    final List<CollectionOperationStatus> mergedOperationStatus = Collections
+            .synchronizedList(new ArrayList<CollectionOperationStatus>(insertList.size()));
 
     final Map<Integer, CollectionOperationStatus> mergedResult =
         new ConcurrentHashMap<Integer, CollectionOperationStatus>();
@@ -4012,12 +4012,12 @@ public Map<Integer, CollectionOperationStatus> get(long duration,
 
       @Override
       public CollectionOperationStatus getOperationStatus() {
-        for (OperationStatus status : mergedOperationStatus) {
+        for (CollectionOperationStatus status : mergedOperationStatus) {
           if (!status.isSuccess()) {
-            return new CollectionOperationStatus(status);
+            return status;
           }
         }
-        return new CollectionOperationStatus(true, "END", CollectionResponse.END);
+        return mergedOperationStatus.get(0);
       }
 
       @Override