diff --git a/src/main/java/org/redisson/api/RBucketReactive.java b/src/main/java/org/redisson/api/RBucketReactive.java index 7e114e11e..04583dab3 100644 --- a/src/main/java/org/redisson/api/RBucketReactive.java +++ b/src/main/java/org/redisson/api/RBucketReactive.java @@ -35,6 +35,4 @@ public interface RBucketReactive extends RExpirableReactive { Publisher set(V value, long timeToLive, TimeUnit timeUnit); - Publisher exists(); - } diff --git a/src/main/java/org/redisson/api/RObjectReactive.java b/src/main/java/org/redisson/api/RObjectReactive.java index 7ed337612..0d9da22f9 100644 --- a/src/main/java/org/redisson/api/RObjectReactive.java +++ b/src/main/java/org/redisson/api/RObjectReactive.java @@ -71,4 +71,11 @@ public interface RObjectReactive { */ Publisher renamenx(String newName); + /** + * Check object existence + * + * @return true if object exists and false otherwise + */ + Publisher isExists(); + } diff --git a/src/main/java/org/redisson/reactive/RedissonBucketReactive.java b/src/main/java/org/redisson/reactive/RedissonBucketReactive.java index 8fd4d13c5..ef1c4cb38 100644 --- a/src/main/java/org/redisson/reactive/RedissonBucketReactive.java +++ b/src/main/java/org/redisson/reactive/RedissonBucketReactive.java @@ -48,9 +48,4 @@ public class RedissonBucketReactive extends RedissonExpirableReactive impleme return commandExecutor.writeReactive(getName(), codec, RedisCommands.SETEX, getName(), timeUnit.toSeconds(timeToLive), value); } - @Override - public Publisher exists() { - return commandExecutor.readReactive(getName(), codec, RedisCommands.EXISTS, getName()); - } - } diff --git a/src/main/java/org/redisson/reactive/RedissonObjectReactive.java b/src/main/java/org/redisson/reactive/RedissonObjectReactive.java index 92e77eaf3..6ce34b040 100644 --- a/src/main/java/org/redisson/reactive/RedissonObjectReactive.java +++ b/src/main/java/org/redisson/reactive/RedissonObjectReactive.java @@ -92,4 +92,9 @@ abstract class RedissonObjectReactive implements RObjectReactive { return commandExecutor.writeReactive(getName(), RedisCommands.DEL_SINGLE, getName()); } + @Override + public Publisher isExists() { + return commandExecutor.readReactive(getName(), codec, RedisCommands.EXISTS, getName()); + } + }