From 9a07b934c9f1c6f0b1ab960ee6411a7cc6907782 Mon Sep 17 00:00:00 2001 From: Nikita Koksharov Date: Wed, 21 Dec 2022 09:46:52 +0300 Subject: [PATCH] Fixed - RSetRx and RSetReactive miss tryAdd method. --- .../src/main/java/org/redisson/api/RSetReactive.java | 10 ++++++++++ redisson/src/main/java/org/redisson/api/RSetRx.java | 9 +++++++++ 2 files changed, 19 insertions(+) diff --git a/redisson/src/main/java/org/redisson/api/RSetReactive.java b/redisson/src/main/java/org/redisson/api/RSetReactive.java index e1cd76a77..83088a09f 100644 --- a/redisson/src/main/java/org/redisson/api/RSetReactive.java +++ b/redisson/src/main/java/org/redisson/api/RSetReactive.java @@ -239,4 +239,14 @@ public interface RSetReactive extends RCollectionReactive, RSortableReacti */ Mono> readIntersection(String... names); + /** + * Tries to add elements only if none of them in set. + * + * @param values - values to add + * @return true if elements successfully added, + * otherwise false. + */ + Mono tryAdd(V... values); + + } diff --git a/redisson/src/main/java/org/redisson/api/RSetRx.java b/redisson/src/main/java/org/redisson/api/RSetRx.java index 5a2d19992..5ce145416 100644 --- a/redisson/src/main/java/org/redisson/api/RSetRx.java +++ b/redisson/src/main/java/org/redisson/api/RSetRx.java @@ -241,4 +241,13 @@ public interface RSetRx extends RCollectionRx, RSortableRx> { */ Single> readIntersection(String... names); + /** + * Tries to add elements only if none of them in set. + * + * @param values - values to add + * @return true if elements successfully added, + * otherwise false. + */ + Single tryAdd(V... values); + }