reactive tests fixed

4 years ago · 07f4e089bd
parent 696a0005f6
commit 07f4e089bd
1 changed files with 1 additions and 1 deletions
--- a/redisson/src/test/java/org/redisson/BaseReactiveTest.java
+++ b/redisson/src/test/java/org/redisson/BaseReactiveTest.java
@ -32,7 +32,7 @@ public abstract class BaseReactiveTest {

    @Before
    public void before() throws IOException, InterruptedException {
-        redisson.getKeys().flushall();
+        sync(redisson.getKeys().flushall());
    }

    public static <V> Iterable<V> sync(RScoredSortedSetReactive<V> list) {