diff --git a/redisson/src/main/java/org/redisson/api/RScoredSortedSetRx.java b/redisson/src/main/java/org/redisson/api/RScoredSortedSetRx.java index 9703c13ff..d11e606a4 100644 --- a/redisson/src/main/java/org/redisson/api/RScoredSortedSetRx.java +++ b/redisson/src/main/java/org/redisson/api/RScoredSortedSetRx.java @@ -429,5 +429,21 @@ public interface RScoredSortedSetRx extends RExpirableRx, RSortableRx> * @return the tail element */ Flowable takeLast(); + + /** + * Retrieves and removes continues stream of elements from the head. + * Waits for next element become available. + * + * @return stream of head elements + */ + Flowable takeFirstElements(); + + /** + * Retrieves and removes continues stream of elements from the tail. + * Waits for next element become available. + * + * @return stream of tail elements + */ + Flowable takeLastElements(); } diff --git a/redisson/src/main/java/org/redisson/rx/RedissonScoredSortedSetRx.java b/redisson/src/main/java/org/redisson/rx/RedissonScoredSortedSetRx.java index 2ce92e155..20a0e7a38 100644 --- a/redisson/src/main/java/org/redisson/rx/RedissonScoredSortedSetRx.java +++ b/redisson/src/main/java/org/redisson/rx/RedissonScoredSortedSetRx.java @@ -48,7 +48,7 @@ public class RedissonScoredSortedSetRx { }.create(); } - public Flowable takeFirst() { + public Flowable takeFirstElements() { return ElementsStream.takeElements(new Callable>() { @Override public RFuture call() throws Exception { @@ -57,7 +57,7 @@ public class RedissonScoredSortedSetRx { }); } - public Flowable takeLast() { + public Flowable takeLastElements() { return ElementsStream.takeElements(new Callable>() { @Override public RFuture call() throws Exception {