Fixed - RKeysRx.getKeys() and RKeysReactive.getKeys() methods aren't working. #2381

redisson/src/main/java/org/redisson/reactive/RedissonKeysReactive.java

@@ -45,6 +45,14 @@ public class RedissonKeysReactive {
         this.commandExecutor = commandExecutor;
     }
 
+    public Flux<String> getKeys() {
+        return getKeysByPattern(null);
+    }
+
+    public Flux<String> getKeys(int count) {
+        return getKeysByPattern(null, count);
+    }
+
     public Flux<String> getKeysByPattern(String pattern) {
         return getKeysByPattern(pattern, 10);
     }

redisson/src/main/java/org/redisson/rx/RedissonKeysRx.java

@@ -42,6 +42,14 @@ public class RedissonKeysRx {
         this.commandExecutor = commandExecutor;
     }
 
+    public Flowable<String> getKeys() {
+        return getKeysByPattern(null);
+    }
+
+    public Flowable<String> getKeys(int count) {
+        return getKeysByPattern(null, count);
+    }
+
     public Flowable<String> getKeysByPattern(String pattern) {
         return getKeysByPattern(pattern, 10);
     }

redisson/src/test/java/org/redisson/RedissonKeysReactiveTest.java

@@ -6,10 +6,22 @@ import static org.assertj.core.api.Assertions.*;
 import org.junit.Assert;
 import org.junit.Test;
 import org.redisson.api.RBucketReactive;
+import org.redisson.api.RKeysReactive;
+import org.redisson.api.RKeysRx;
 import org.redisson.api.RMapReactive;
+import reactor.core.publisher.Flux;
 
 public class RedissonKeysReactiveTest extends BaseReactiveTest {
 
+    @Test
+    public void testGetKeys() {
+        RKeysReactive keys = redisson.getKeys();
+        sync(redisson.getBucket("test1").set(1));
+        sync(redisson.getBucket("test2").set(1));
+        Flux<String> k = keys.getKeys();
+        assertThat(k.toIterable()).contains("test1", "test2");
+    }
+
     @Test
     public void testKeysIterablePattern() {
         sync(redisson.getBucket("test1").set("someValue"));

redisson/src/test/java/org/redisson/rx/RedissonKeysRxTest.java

@@ -1,16 +1,28 @@
 package org.redisson.rx;
 
-import static org.assertj.core.api.Assertions.assertThat;
-
-import java.util.Iterator;
-
+import io.reactivex.Flowable;
 import org.junit.Assert;
 import org.junit.Test;
 import org.redisson.api.RBucketRx;
+import org.redisson.api.RKeysRx;
 import org.redisson.api.RMapRx;
+import reactor.core.publisher.Flux;
+
+import java.util.Iterator;
+
+import static org.assertj.core.api.Assertions.assertThat;
 
 public class RedissonKeysRxTest extends BaseRxTest {
 
+    @Test
+    public void testGetKeys() {
+        RKeysRx keys = redisson.getKeys();
+        sync(redisson.getBucket("test1").set(1));
+        sync(redisson.getBucket("test2").set(1));
+        Flowable<String> k = keys.getKeys();
+        assertThat(k.blockingIterable()).contains("test1", "test2");
+    }
+
     @Test
     public void testKeysIterablePattern() {
         sync(redisson.getBucket("test1").set("someValue"));