From f5631f941ad4de37389a1cfde53b4aaebdcbcf5f Mon Sep 17 00:00:00 2001
From: Nikita <abracham.mitchell@gmail.com>
Date: Fri, 12 Oct 2018 18:21:27 +0300
Subject: [PATCH] refactoring

---
 .../redisson/reactive/RedissonScoredSortedSetReactive.java | 2 +-
 redisson/src/test/java/org/redisson/rx/BaseRxTest.java     | 7 ++++---
 2 files changed, 5 insertions(+), 4 deletions(-)

diff --git a/redisson/src/main/java/org/redisson/reactive/RedissonScoredSortedSetReactive.java b/redisson/src/main/java/org/redisson/reactive/RedissonScoredSortedSetReactive.java
index eb3cb5323..254c591dd 100644
--- a/redisson/src/main/java/org/redisson/reactive/RedissonScoredSortedSetReactive.java
+++ b/redisson/src/main/java/org/redisson/reactive/RedissonScoredSortedSetReactive.java
@@ -60,7 +60,7 @@ public class RedissonScoredSortedSetReactive<V>  {
     }
 
     public String getName() {
-        return ((RedissonScoredSortedSet)instance).getName();
+        return ((RedissonScoredSortedSet<V>)instance).getName();
     }
     
     public Publisher<V> iterator() {
diff --git a/redisson/src/test/java/org/redisson/rx/BaseRxTest.java b/redisson/src/test/java/org/redisson/rx/BaseRxTest.java
index e543ba739..ca782a6c8 100644
--- a/redisson/src/test/java/org/redisson/rx/BaseRxTest.java
+++ b/redisson/src/test/java/org/redisson/rx/BaseRxTest.java
@@ -12,6 +12,7 @@ import org.redisson.BaseTest;
 import org.redisson.RedisRunner;
 import org.redisson.Redisson;
 import org.redisson.api.RCollectionRx;
+import org.redisson.api.RScoredSortedSetRx;
 import org.redisson.api.RedissonRxClient;
 import org.redisson.config.Config;
 
@@ -42,9 +43,9 @@ public abstract class BaseRxTest {
         sync(redisson.getKeys().flushall());
     }
 
-//    public static <V> Iterable<V> sync(RScoredSortedSetReactive<V> list) {
-//        return Streams.create(list.iterator()).toList().poll();
-//    }
+    public static <V> Iterable<V> sync(RScoredSortedSetRx<V> list) {
+        return list.iterator().toList().blockingGet();
+    }
 
     public static <V> Iterable<V> sync(RCollectionRx<V> list) {
         return list.iterator().toList().blockingGet();