|
|
|
@ -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<V> extends RCollectionReactive<V>, RSortableReacti
|
|
|
|
|
*/
|
|
|
|
|
Mono<Boolean> 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<List<V>> containsEach(Collection<V> c);
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|