Fixed - RQueueReactive.poll(int limit) should return Mono<List<V>> and RQueueRx.poll(int limit) should return Single<List<V>>. #2815

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

@@ -49,7 +49,7 @@ public interface RQueueReactive<V> extends RCollectionReactive<V> {
      *
      * @return list of head elements
      */
-    Flux<V> poll(int limit);
+    Mono<List<V>> poll(int limit);
 
     /**
      * Inserts the specified element into this queue.

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

@@ -50,7 +50,7 @@ public interface RQueueRx<V> extends RCollectionRx<V> {
      *
      * @return list of head elements
      */
-    Flowable<V> poll(int limit);
+    Single<List<V>> poll(int limit);
 
     /**
      * Inserts the specified element into this queue.