diff --git a/src/main/java/net/spy/memcached/v2/AsyncArcusCommands.java b/src/main/java/net/spy/memcached/v2/AsyncArcusCommands.java index abb8fee8a..ee02489c6 100644 --- a/src/main/java/net/spy/memcached/v2/AsyncArcusCommands.java +++ b/src/main/java/net/spy/memcached/v2/AsyncArcusCommands.java @@ -927,9 +927,11 @@ public void receivedStatus(OperationStatus status) { result.set(new AbstractMap.SimpleEntry<>(true, trimmedElement)); break; case ERR_ELEMENT_EXISTS: - case ERR_NOT_FOUND: result.set(new AbstractMap.SimpleEntry<>(false, trimmedElement)); break; + case ERR_NOT_FOUND: + result.set(null); + break; case CANCELLED: future.internalCancel(); break; @@ -1046,6 +1048,7 @@ public ArcusFuture> bopGet(String key, BKey from, BKey to, BopG public void receivedStatus(OperationStatus status) { switch (status.getStatusCode()) { case SUCCESS: + case ERR_NOT_FOUND_ELEMENT: break; case TRIMMED: result.get().trimmed(); @@ -1053,8 +1056,6 @@ public void receivedStatus(OperationStatus status) { case ERR_NOT_FOUND: result.set(null); break; - case ERR_NOT_FOUND_ELEMENT: - break; case CANCELLED: future.internalCancel(); break;