RSetReactive.readIntersection added

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

@@ -90,4 +90,13 @@ public interface RSetReactive<V> extends RCollectionReactive<V> {
      */
     Publisher<Long> intersection(String... names);
 
+    /**
+     * Intersection sets specified by name with current set.
+     * Without current set state change.
+     *
+     * @param names
+     * @return
+     */
+    Publisher<Set<V>> readIntersection(String... names);
+
 }

src/main/java/org/redisson/reactive/RedissonSetReactive.java

@@ -118,6 +118,11 @@ public class RedissonSetReactive<V> extends RedissonExpirableReactive implements
         return reactive(instance.removeAllAsync(c));
     }
 
+    @Override
+    public Publisher<Set<V>> readIntersection(String... names) {
+        return reactive(instance.readIntersectionAsync(names));
+    }
+    
     @Override
     public Publisher<Long> intersection(String... names) {
         List<Object> args = new ArrayList<Object>(names.length + 1);