refactoring

redisson/src/test/java/org/redisson/BaseReactiveTest.java

@@ -74,8 +74,12 @@ public abstract class BaseReactiveTest {
         return Flux.from(pub).toIterable();
     }
 
-    public static <V> V sync(Publisher<V> ob) {
+    public static <V> V sync(Mono<V> mono) {
-        return Mono.from(ob).block();
+        return mono.block();
+    }
+    
+    public static <V> V sync(Flux<V> flux) {
+        return flux.single().block();
     }
 
     public static RedissonReactiveClient createInstance() {