fix

naver · Aug 11, 2023 · c4df236 · c4df236
1 parent 29988a2
commit c4df236
Showing 1 changed file with 2 additions and 17 deletions.
diff --git a/src/main/java/net/spy/memcached/ArcusClient.java b/src/main/java/net/spy/memcached/ArcusClient.java
@@ -3563,23 +3563,8 @@ public CollectionFuture<Integer> asyncBopGetItemCount(String key,
   }
 
   @Override
-  public CollectionFuture<Map<Object, Boolean>> asyncSopPipedExistBulk(String key,
-                                                                       List<Object> values) {
-    if (values.size() == 0) {
-      throw new IllegalArgumentException(
-              "The number of piped operations must be larger than 0.");
-    }
-
-    List<SetPipedExist<Object>> existList = new ArrayList<SetPipedExist<Object>>();
-    if (values.size() <= SetPipedExist.MAX_PIPED_ITEM_COUNT) {
-      existList.add(new SetPipedExist<Object>(key, values, collectionTranscoder));
-    } else {
-      PartitionedList<Object> partitionedList = new PartitionedList<Object>(values, SetPipedExist.MAX_PIPED_ITEM_COUNT);
-      for (List<Object> partition : partitionedList) {
-        existList.add(new SetPipedExist<Object>(key, partition, collectionTranscoder));
-      }
-    }
-    return asyncSetPipedExist(key, existList);
+  public CollectionFuture<Map<Object, Boolean>> asyncSopPipedExistBulk(String key, List<Object> values) {
+    return asyncSopPipedExistBulk(key, values, collectionTranscoder);
   }
 
   @Override