diff --git a/src/main/java/net/spy/memcached/ArcusClient.java b/src/main/java/net/spy/memcached/ArcusClient.java
index 77fcb811b..d8f706118 100644
--- a/src/main/java/net/spy/memcached/ArcusClient.java
+++ b/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,9 +1058,9 @@ 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);
@@ -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,9 +4012,9 @@ 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);