Class RedissonSetRx<V>

  • Type Parameters:
    V - value

    public class RedissonSetRx<V>
    extends Object
    Distributed and concurrent implementation of Set
    Author:
    Nikita Koksharov
    • Method Detail

      • addAll

        public io.reactivex.rxjava3.core.Single<Boolean> addAll​(org.reactivestreams.Publisher<? extends V> c)
      • iterator

        public io.reactivex.rxjava3.core.Flowable<V> iterator​(int count)
      • iterator

        public io.reactivex.rxjava3.core.Flowable<V> iterator​(String pattern)
      • iterator

        public io.reactivex.rxjava3.core.Flowable<V> iterator​(String pattern,
                                                              int count)
      • iterator

        public org.reactivestreams.Publisher<V> iterator()
      • getFairLock

        public RLockRx getFairLock​(V value)
      • getLock

        public RLockRx getLock​(V value)