refactoring

redisson · Mar 18, 2019 · e5c84d7 · e5c84d7
1 parent c19e9ab
commit e5c84d7
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/redisson/src/test/java/org/redisson/BaseReactiveTest.java b/redisson/src/test/java/org/redisson/BaseReactiveTest.java
@@ -74,8 +74,12 @@ public static <V> Iterable<V> toIterable(Publisher<V> pub) {
         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() {