diff --git a/src/main/java/org/redisson/api/RBatchReactive.java b/src/main/java/org/redisson/api/RBatchReactive.java index 5e1578494..aa17bdaff 100644 --- a/src/main/java/org/redisson/api/RBatchReactive.java +++ b/src/main/java/org/redisson/api/RBatchReactive.java @@ -164,13 +164,13 @@ public interface RBatchReactive { */ RScriptReactive getScript(); -// /** -// * Returns keys operations. -// * Each of Redis/Redisson object associated with own key -// * -// * @return -// */ -// RKeysReactive getKeys(); + /** + * Returns keys operations. + * Each of Redis/Redisson object associated with own key + * + * @return + */ + RKeysReactive getKeys(); /** * Executes all operations accumulated during Reactive methods invocations Reactivehronously. diff --git a/src/main/java/org/redisson/reactive/RedissonBatchReactive.java b/src/main/java/org/redisson/reactive/RedissonBatchReactive.java index ffff021f6..4f9edfa36 100644 --- a/src/main/java/org/redisson/reactive/RedissonBatchReactive.java +++ b/src/main/java/org/redisson/reactive/RedissonBatchReactive.java @@ -25,6 +25,7 @@ import org.redisson.api.RBlockingQueueReactive; import org.redisson.api.RBucketReactive; import org.redisson.api.RDequeReactive; import org.redisson.api.RHyperLogLogReactive; +import org.redisson.api.RKeysReactive; import org.redisson.api.RLexSortedSetReactive; import org.redisson.api.RListReactive; import org.redisson.api.RMapReactive; @@ -165,10 +166,10 @@ public class RedissonBatchReactive implements RBatchReactive { return new RedissonScriptReactive(executorService); } -// @Override -// public RKeysReactive getKeys() { -// return new RedissonKeys(executorService); -// } + @Override + public RKeysReactive getKeys() { + return new RedissonKeysReactive(executorService); + } @Override public Publisher> executeReactive() {