diff --git a/redisson/src/main/java/org/redisson/api/RSetReactive.java b/redisson/src/main/java/org/redisson/api/RSetReactive.java index 83088a09f..bce95510c 100644 --- a/redisson/src/main/java/org/redisson/api/RSetReactive.java +++ b/redisson/src/main/java/org/redisson/api/RSetReactive.java @@ -19,6 +19,7 @@ import reactor.core.publisher.Flux; import reactor.core.publisher.Mono; import java.util.Collection; +import java.util.List; import java.util.Set; /** @@ -248,5 +249,13 @@ public interface RSetReactive extends RCollectionReactive, RSortableReacti */ Mono tryAdd(V... values); + /** + * Check if each element is contained in the specified collection. + * Returns contained elements. + * + * @param c - collection to check + * @return contained elements + */ + Mono> containsEach(Collection c); } diff --git a/redisson/src/main/java/org/redisson/api/RSetRx.java b/redisson/src/main/java/org/redisson/api/RSetRx.java index 5ce145416..b660bb0bc 100644 --- a/redisson/src/main/java/org/redisson/api/RSetRx.java +++ b/redisson/src/main/java/org/redisson/api/RSetRx.java @@ -16,6 +16,7 @@ package org.redisson.api; import java.util.Collection; +import java.util.List; import java.util.Set; import io.reactivex.rxjava3.core.Flowable; @@ -250,4 +251,13 @@ public interface RSetRx extends RCollectionRx, RSortableRx> { */ Single tryAdd(V... values); + /** + * Check if each element is contained in the specified collection. + * Returns contained elements. + * + * @param c - collection to check + * @return contained elements + */ + Single> containsEach(Collection c); + }