Package org.redisson.rx
Class RedissonMapRx<K,V>
-
- org.redisson.rx.RedissonMapRx<K,V>
-
- Type Parameters:
K
- keyV
- value
- Direct Known Subclasses:
RedissonMapCacheRx
public class RedissonMapRx<K,V> extends
Distributed and concurrent implementation of and- Author:
- Nikita Koksharov
-
-
Constructor Summary
Constructors Constructor Description RedissonMapRx(RMap<K,V> instance, CommandRxExecutor executor)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.reactivestreams.Publisher<<K,V>>
entryIterator()
org.reactivestreams.Publisher<<K,V>>
entryIterator(int count)
org.reactivestreams.Publisher<<K,V>>
pattern)
org.reactivestreams.Publisher<<K,V>>
pattern, int count)
RLockRx
getFairLock(K key)
RLockRx
getLock(K key)
RPermitExpirableSemaphoreRx
getPermitExpirableSemaphore(K key)
RReadWriteLockRx
getReadWriteLock(K key)
RSemaphoreRx
getSemaphore(K key)
org.reactivestreams.Publisher<K>
keyIterator()
org.reactivestreams.Publisher<K>
keyIterator(int count)
org.reactivestreams.Publisher<K>
pattern)
org.reactivestreams.Publisher<K>
pattern, int count)
org.reactivestreams.Publisher<V>
valueIterator()
org.reactivestreams.Publisher<V>
valueIterator(int count)
org.reactivestreams.Publisher<V>
pattern)
org.reactivestreams.Publisher<V>
pattern, int count)
-
-
-
Constructor Detail
-
RedissonMapRx
public RedissonMapRx(RMap<K,V> instance, CommandRxExecutor executor)
-
-
Method Detail
-
entryIterator
public org.reactivestreams.Publisher<< pattern)
-
entryIterator
public org.reactivestreams.Publisher<< pattern, int count)
-
valueIterator
public org.reactivestreams.Publisher<V> valueIterator()
-
valueIterator
public org.reactivestreams.Publisher< pattern)
-
valueIterator
public org.reactivestreams.Publisher<V> valueIterator(int count)
-
valueIterator
public org.reactivestreams.Publisher< pattern, int count)
-
keyIterator
public org.reactivestreams.Publisher<K> keyIterator()
-
keyIterator
public org.reactivestreams.Publisher< pattern)
-
keyIterator
public org.reactivestreams.Publisher<K> keyIterator(int count)
-
keyIterator
public org.reactivestreams.Publisher< pattern, int count)
-
getPermitExpirableSemaphore
public RPermitExpirableSemaphoreRx getPermitExpirableSemaphore(K key)
-
getSemaphore
public RSemaphoreRx getSemaphore(K key)
-
getReadWriteLock
public RReadWriteLockRx getReadWriteLock(K key)
-
-