Merge branch 'master' into 3.0.0

redisson/src/main/java/org/redisson/api/RScoredSortedSetRx.java

@@ -429,5 +429,21 @@ public interface RScoredSortedSetRx<V> extends RExpirableRx, RSortableRx<Set<V>>
      * @return the tail element
      */
     Flowable<V> takeLast();
+
+    /**
+     * Retrieves and removes continues stream of elements from the head. 
+     * Waits for next element become available.
+     * 
+     * @return stream of head elements
+     */
+    Flowable<V> takeFirstElements();
+
+    /**
+     * Retrieves and removes continues stream of elements from the tail. 
+     * Waits for next element become available.
+     * 
+     * @return stream of tail elements
+     */
+    Flowable<V> takeLastElements();
     
 }

redisson/src/main/java/org/redisson/rx/RedissonScoredSortedSetRx.java

@@ -48,7 +48,7 @@ public class RedissonScoredSortedSetRx<V>  {
         }.create();
     }
 
-    public Flowable<V> takeFirst() {
+    public Flowable<V> takeFirstElements() {
         return ElementsStream.takeElements(new Callable<RFuture<V>>() {
             @Override
             public RFuture<V> call() throws Exception {
@@ -57,7 +57,7 @@ public class RedissonScoredSortedSetRx<V>  {
         });
     }
     
-    public Flowable<V> takeLast() {
+    public Flowable<V> takeLastElements() {
         return ElementsStream.takeElements(new Callable<RFuture<V>>() {
             @Override
             public RFuture<V> call() throws Exception {