Package org.redisson.rx
Class RedissonSetRx<V>
- java.lang.Object
-
- org.redisson.rx.RedissonSetRx<V>
-
-
Constructor Summary
Constructors Constructor Description RedissonSetRx(RSet<V> instance, RedissonRxClient redisson)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description io.reactivex.rxjava3.core.Single<Boolean>
addAll(org.reactivestreams.Publisher<? extends V> c)
RLockRx
getFairLock(V value)
RLockRx
getLock(V value)
RPermitExpirableSemaphoreRx
getPermitExpirableSemaphore(V value)
RReadWriteLockRx
getReadWriteLock(V value)
RSemaphoreRx
getSemaphore(V value)
org.reactivestreams.Publisher<V>
iterator()
io.reactivex.rxjava3.core.Flowable<V>
iterator(int count)
io.reactivex.rxjava3.core.Flowable<V>
iterator(String pattern)
io.reactivex.rxjava3.core.Flowable<V>
iterator(String pattern, int count)
-
-
-
Constructor Detail
-
RedissonSetRx
public RedissonSetRx(RSet<V> instance, RedissonRxClient redisson)
-
-
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 org.reactivestreams.Publisher<V> iterator()
-
getPermitExpirableSemaphore
public RPermitExpirableSemaphoreRx getPermitExpirableSemaphore(V value)
-
getSemaphore
public RSemaphoreRx getSemaphore(V value)
-
getReadWriteLock
public RReadWriteLockRx getReadWriteLock(V value)
-
-