diff --git a/redisson/src/main/java/org/redisson/api/RScoredSortedSetReactive.java b/redisson/src/main/java/org/redisson/api/RScoredSortedSetReactive.java index 11ea2e90a..c6fc59a52 100644 --- a/redisson/src/main/java/org/redisson/api/RScoredSortedSetReactive.java +++ b/redisson/src/main/java/org/redisson/api/RScoredSortedSetReactive.java @@ -695,6 +695,45 @@ public interface RScoredSortedSetReactive extends RExpirableReactive, RSortab */ Mono union(Aggregate aggregate, Map nameWithWeight); + /** + * Union ScoredSortedSets specified by name with current ScoredSortedSet + * without state change. + * + * @param names - names of ScoredSortedSet + * @return length of union + */ + Mono> readUnion(String... names); + + /** + * Union ScoredSortedSets specified by name with defined aggregation method + * and current ScoredSortedSet without state change. + * + * @param aggregate - score aggregation mode + * @param names - names of ScoredSortedSet + * @return length of union + */ + Mono> readUnion(Aggregate aggregate, String... names); + + /** + * Union provided ScoredSortedSets mapped to weight multiplier + * and current ScoredSortedSet without state change. + * + * @param nameWithWeight - name of ScoredSortedSet mapped to weight multiplier + * @return length of union + */ + Mono> readUnion(Map nameWithWeight); + + /** + * Union provided ScoredSortedSets mapped to weight multiplier + * with defined aggregation method + * and current ScoredSortedSet without state change + * + * @param aggregate - score aggregation mode + * @param nameWithWeight - name of ScoredSortedSet mapped to weight multiplier + * @return length of union + */ + Mono> readUnion(Aggregate aggregate, Map nameWithWeight); + /** * Removes and returns the head element waiting if necessary for an element to become available. * diff --git a/redisson/src/main/java/org/redisson/api/RScoredSortedSetRx.java b/redisson/src/main/java/org/redisson/api/RScoredSortedSetRx.java index 3c69cb577..c4e7cd0f2 100644 --- a/redisson/src/main/java/org/redisson/api/RScoredSortedSetRx.java +++ b/redisson/src/main/java/org/redisson/api/RScoredSortedSetRx.java @@ -697,6 +697,45 @@ public interface RScoredSortedSetRx extends RExpirableRx, RSortableRx> */ Single union(Aggregate aggregate, Map nameWithWeight); + /** + * Union ScoredSortedSets specified by name with current ScoredSortedSet + * without state change. + * + * @param names - names of ScoredSortedSet + * @return length of union + */ + Single> readUnion(String... names); + + /** + * Union ScoredSortedSets specified by name with defined aggregation method + * and current ScoredSortedSet without state change. + * + * @param aggregate - score aggregation mode + * @param names - names of ScoredSortedSet + * @return length of union + */ + Single> readUnion(Aggregate aggregate, String... names); + + /** + * Union provided ScoredSortedSets mapped to weight multiplier + * and current ScoredSortedSet without state change. + * + * @param nameWithWeight - name of ScoredSortedSet mapped to weight multiplier + * @return length of union + */ + Single> readUnion(Map nameWithWeight); + + /** + * Union provided ScoredSortedSets mapped to weight multiplier + * with defined aggregation method + * and current ScoredSortedSet without state change + * + * @param aggregate - score aggregation mode + * @param nameWithWeight - name of ScoredSortedSet mapped to weight multiplier + * @return length of union + */ + Single> readUnion(Aggregate aggregate, Map nameWithWeight); + /** * Removes and returns the head element waiting if necessary for an element to become available. *