From 6226feb1f2f8271280d45667d877067449011329 Mon Sep 17 00:00:00 2001
From: Nikita Koksharov <nkoksharov@redisson.pro>
Date: Wed, 21 Nov 2018 12:33:24 +0300
Subject: [PATCH] refactoring

---
 .../org/redisson/api/RScoredSortedSetReactive.java   |  4 ++--
 .../reactive/RedissonScoredSortedSetReactive.java    | 12 ++++++------
 2 files changed, 8 insertions(+), 8 deletions(-)

diff --git a/redisson/src/main/java/org/redisson/api/RScoredSortedSetReactive.java b/redisson/src/main/java/org/redisson/api/RScoredSortedSetReactive.java
index f853fe329..e5e50c536 100644
--- a/redisson/src/main/java/org/redisson/api/RScoredSortedSetReactive.java
+++ b/redisson/src/main/java/org/redisson/api/RScoredSortedSetReactive.java
@@ -422,13 +422,13 @@ public interface RScoredSortedSetReactive<V> extends RExpirableReactive, RSortab
      *
      * @return the head element
      */
-    Publisher<V> takeFirst();
+    Mono<V> takeFirst();
 
     /**
      * Removes and returns the tail element waiting if necessary for an element to become available.
      *
      * @return the tail element
      */
-    Publisher<V> takeLast();
+    Mono<V> takeLast();
     
 }
diff --git a/redisson/src/main/java/org/redisson/reactive/RedissonScoredSortedSetReactive.java b/redisson/src/main/java/org/redisson/reactive/RedissonScoredSortedSetReactive.java
index 506c76a12..21afb5506 100644
--- a/redisson/src/main/java/org/redisson/reactive/RedissonScoredSortedSetReactive.java
+++ b/redisson/src/main/java/org/redisson/reactive/RedissonScoredSortedSetReactive.java
@@ -51,7 +51,7 @@ public class RedissonScoredSortedSetReactive<V>  {
         this.instance = instance;
     }
 
-    private Publisher<V> scanIteratorReactive(final String pattern, final int count) {
+    private Flux<V> scanIteratorReactive(final String pattern, final int count) {
         return Flux.create(new SetReactiveIterator<V>() {
             @Override
             protected RFuture<ListScanResult<Object>> scanIterator(final RedisClient client, final long nextIterPos) {
@@ -64,20 +64,20 @@ public class RedissonScoredSortedSetReactive<V>  {
         return ((RedissonScoredSortedSet<V>)instance).getName();
     }
     
-    public Publisher<V> iterator() {
+    public Flux<V> iterator() {
         return scanIteratorReactive(null, 10);
     }
 
-    public Publisher<V> iterator(String pattern) {
+    public Flux<V> iterator(String pattern) {
         return scanIteratorReactive(pattern, 10);
     }
 
-    public Publisher<V> iterator(int count) {
+    public Flux<V> iterator(int count) {
         return scanIteratorReactive(null, count);
     }
 
-    public Publisher<V> iterator(String pattern, int count) {
+    public Flux<V> iterator(String pattern, int count) {
         return scanIteratorReactive(pattern, count);
     }
 
-            }
+}