From c4df236df4df46bc705b1aa8445b26d368907e63 Mon Sep 17 00:00:00 2001
From: brido4125 <hcs4125@gmail.com>
Date: Fri, 11 Aug 2023 16:18:10 +0900
Subject: [PATCH] fix

---
 .../java/net/spy/memcached/ArcusClient.java   | 19 ++-----------------
 1 file changed, 2 insertions(+), 17 deletions(-)

diff --git a/src/main/java/net/spy/memcached/ArcusClient.java b/src/main/java/net/spy/memcached/ArcusClient.java
index 6eecdc63b..de2cd45c9 100644
--- 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