Package org.redisson.rx

Class RedissonMapRx<K,V>

java.lang.Object

org.redisson.rx.RedissonMapRx<K,V>

Type Parameters:

K - key

V - value

Direct Known Subclasses:

RedissonMapCacheRx

public class RedissonMapRx<K,V>
extends Object

Distributed and concurrent implementation of ConcurrentMap and Map

Author:

Nikita Koksharov

Constructor Summary

Constructors

Constructor	Description
RedissonMapRx(RMap<K,V> instance, CommandRxExecutor executor)

Method Summary

Modifier and Type	Method	Description
org.reactivestreams.Publisher<Map.Entry<K,V>>	entryIterator()
org.reactivestreams.Publisher<Map.Entry<K,V>>	entryIterator(int count)
org.reactivestreams.Publisher<Map.Entry<K,V>>	entryIterator(String pattern)
org.reactivestreams.Publisher<Map.Entry<K,V>>	entryIterator(String 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>	keyIterator(String pattern)
org.reactivestreams.Publisher<K>	keyIterator(String pattern, int count)
org.reactivestreams.Publisher<V>	valueIterator()
org.reactivestreams.Publisher<V>	valueIterator(int count)
org.reactivestreams.Publisher<V>	valueIterator(String pattern)
org.reactivestreams.Publisher<V>	valueIterator(String pattern, int count)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RedissonMapRx

public RedissonMapRx(RMap<K,V> instance,
                     CommandRxExecutor executor)

Method Detail

entryIterator

public org.reactivestreams.Publisher<Map.Entry<K,V>> entryIterator()

entryIterator

public org.reactivestreams.Publisher<Map.Entry<K,V>> entryIterator(int count)

entryIterator

public org.reactivestreams.Publisher<Map.Entry<K,V>> entryIterator(String pattern)

entryIterator

public org.reactivestreams.Publisher<Map.Entry<K,V>> entryIterator(String pattern,
                                                                         int count)

valueIterator

public org.reactivestreams.Publisher<V> valueIterator()

valueIterator

public org.reactivestreams.Publisher<V> valueIterator(String pattern)

valueIterator

public org.reactivestreams.Publisher<V> valueIterator(int count)

valueIterator

public org.reactivestreams.Publisher<V> valueIterator(String pattern,
                                                      int count)

keyIterator

public org.reactivestreams.Publisher<K> keyIterator()

keyIterator

public org.reactivestreams.Publisher<K> keyIterator(String pattern)

keyIterator

public org.reactivestreams.Publisher<K> keyIterator(int count)

keyIterator

public org.reactivestreams.Publisher<K> keyIterator(String pattern,
                                                    int count)

getPermitExpirableSemaphore

public RPermitExpirableSemaphoreRx getPermitExpirableSemaphore(K key)

getSemaphore

public RSemaphoreRx getSemaphore(K key)

getFairLock

public RLockRx getFairLock(K key)

getReadWriteLock

public RReadWriteLockRx getReadWriteLock(K key)

getLock

public RLockRx getLock(K key)