refactoring

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

@@ -325,6 +325,16 @@ public interface RTimeSeriesReactive<V, L> extends RExpirableReactive {
      */
     Mono<Collection<V>> range(long startTimestamp, long endTimestamp);
 
+    /**
+     * Returns ordered elements of this time-series collection within timestamp range. Including boundary values.
+     *
+     * @param startTimestamp start timestamp
+     * @param endTimestamp end timestamp
+     * @param limit result size limit
+     * @return elements collection
+     */
+    Mono<Collection<V>> range(long startTimestamp, long endTimestamp, int limit);
+
     /**
      * Returns elements of this time-series collection in reverse order within timestamp range. Including boundary values.
      *
@@ -334,6 +344,16 @@ public interface RTimeSeriesReactive<V, L> extends RExpirableReactive {
      */
     Mono<Collection<V>> rangeReversed(long startTimestamp, long endTimestamp);
 
+    /**
+     * Returns elements of this time-series collection in reverse order within timestamp range. Including boundary values.
+     *
+     * @param startTimestamp start timestamp
+     * @param endTimestamp end timestamp
+     * @param limit result size limit
+     * @return elements collection
+     */
+    Mono<Collection<V>> rangeReversed(long startTimestamp, long endTimestamp, int limit);
+
     /**
      * Returns ordered entries of this time-series collection within timestamp range. Including boundary values.
      *
@@ -343,6 +363,16 @@ public interface RTimeSeriesReactive<V, L> extends RExpirableReactive {
      */
     Mono<Collection<TimeSeriesEntry<V, L>>> entryRange(long startTimestamp, long endTimestamp);
 
+    /**
+     * Returns ordered entries of this time-series collection within timestamp range. Including boundary values.
+     *
+     * @param startTimestamp start timestamp
+     * @param endTimestamp end timestamp
+     * @param limit result size limit
+     * @return elements collection
+     */
+    Mono<Collection<TimeSeriesEntry<V, L>>> entryRange(long startTimestamp, long endTimestamp, int limit);
+
     /**
      * Returns entries of this time-series collection in reverse order within timestamp range. Including boundary values.
      *
@@ -352,4 +382,14 @@ public interface RTimeSeriesReactive<V, L> extends RExpirableReactive {
      */
     Mono<Collection<TimeSeriesEntry<V, L>>> entryRangeReversed(long startTimestamp, long endTimestamp);
 
+    /**
+     * Returns entries of this time-series collection in reverse order within timestamp range. Including boundary values.
+     *
+     * @param startTimestamp start timestamp
+     * @param endTimestamp end timestamp
+     * @param limit result size limit
+     * @return elements collection
+     */
+    Mono<Collection<TimeSeriesEntry<V, L>>> entryRangeReversed(long startTimestamp, long endTimestamp, int limit);
+
 }

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

@@ -166,7 +166,7 @@ public interface RTimeSeriesRx<V, L> extends RExpirableRx {
      * @param timestamp - object timestamp
      * @return entry or <code>null</code> if it doesn't exist
      */
-    Maybe<TimeSeriesEntry<V, L>>     getAndRemoveEntry(long timestamp);
+    Maybe<TimeSeriesEntry<V, L>> getAndRemoveEntry(long timestamp);
 
     /**
      * Removes and returns the head elements or {@code null} if this time-series collection is empty.
@@ -323,6 +323,16 @@ public interface RTimeSeriesRx<V, L> extends RExpirableRx {
      */
     Single<Collection<V>> range(long startTimestamp, long endTimestamp);
 
+    /**
+     * Returns ordered elements of this time-series collection within timestamp range. Including boundary values.
+     *
+     * @param startTimestamp start timestamp
+     * @param endTimestamp end timestamp
+     * @param limit result size limit
+     * @return elements collection
+     */
+    Single<Collection<V>> range(long startTimestamp, long endTimestamp, int limit);
+
     /**
      * Returns elements of this time-series collection in reverse order within timestamp range. Including boundary values.
      *
@@ -332,6 +342,16 @@ public interface RTimeSeriesRx<V, L> extends RExpirableRx {
      */
     Single<Collection<V>> rangeReversed(long startTimestamp, long endTimestamp);
 
+    /**
+     * Returns elements of this time-series collection in reverse order within timestamp range. Including boundary values.
+     *
+     * @param startTimestamp start timestamp
+     * @param endTimestamp end timestamp
+     * @param limit result size limit
+     * @return elements collection
+     */
+    Single<Collection<V>> rangeReversed(long startTimestamp, long endTimestamp, int limit);
+
     /**
      * Returns ordered entries of this time-series collection within timestamp range. Including boundary values.
      *
@@ -341,6 +361,16 @@ public interface RTimeSeriesRx<V, L> extends RExpirableRx {
      */
     Single<Collection<TimeSeriesEntry<V, L>>> entryRange(long startTimestamp, long endTimestamp);
 
+    /**
+     * Returns ordered entries of this time-series collection within timestamp range. Including boundary values.
+     *
+     * @param startTimestamp start timestamp
+     * @param endTimestamp end timestamp
+     * @param limit result size limit
+     * @return elements collection
+     */
+    Single<Collection<TimeSeriesEntry<V, L>>> entryRange(long startTimestamp, long endTimestamp, int limit);
+
     /**
      * Returns entries of this time-series collection in reverse order within timestamp range. Including boundary values.
      *
@@ -350,4 +380,14 @@ public interface RTimeSeriesRx<V, L> extends RExpirableRx {
      */
     Single<Collection<TimeSeriesEntry<V, L>>> entryRangeReversed(long startTimestamp, long endTimestamp);
 
+    /**
+     * Returns entries of this time-series collection in reverse order within timestamp range. Including boundary values.
+     *
+     * @param startTimestamp start timestamp
+     * @param endTimestamp end timestamp
+     * @param limit result size limit
+     * @return elements collection
+     */
+    Single<Collection<TimeSeriesEntry<V, L>>> entryRangeReversed(long startTimestamp, long endTimestamp, int limit);
+
 }