From 0287372ce0b1868276dca8e37725e8f1f84db578 Mon Sep 17 00:00:00 2001
From: Nikita <abracham.mitchell@gmail.com>
Date: Tue, 8 Dec 2015 11:30:18 +0300
Subject: [PATCH] RObjectReactive.isExists added.  #316

---
 src/main/java/org/redisson/api/RBucketReactive.java        | 2 --
 src/main/java/org/redisson/api/RObjectReactive.java        | 7 +++++++
 .../java/org/redisson/reactive/RedissonBucketReactive.java | 5 -----
 .../java/org/redisson/reactive/RedissonObjectReactive.java | 5 +++++
 4 files changed, 12 insertions(+), 7 deletions(-)

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<V> extends RExpirableReactive {
 
     Publisher<Void> set(V value, long timeToLive, TimeUnit timeUnit);
 
-    Publisher<Boolean> 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<Boolean> renamenx(String newName);
 
+    /**
+     * Check object existence
+     *
+     * @return <code>true</code> if object exists and <code>false</code> otherwise
+     */
+    Publisher<Boolean> 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<V> extends RedissonExpirableReactive impleme
         return commandExecutor.writeReactive(getName(), codec, RedisCommands.SETEX, getName(), timeUnit.toSeconds(timeToLive), value);
     }
 
-    @Override
-    public Publisher<Boolean> 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<Boolean> isExists() {
+        return commandExecutor.readReactive(getName(), codec, RedisCommands.EXISTS, getName());
+    }
+
 }