public class InfinispanAsyncMapImpl<K,V> extends Object implements AsyncMap<K,V>, InfinispanAsyncMap<K,V>
| Constructor and Description |
|---|
InfinispanAsyncMapImpl(VertxInternal vertx,
org.infinispan.Cache<byte[],byte[]> cache) |
| Modifier and Type | Method and Description |
|---|---|
Future<Void> |
clear()
Same as
AsyncMap.clear(Handler) but returns a Future of the asynchronous result |
Future<Map<K,V>> |
entries()
Same as
AsyncMap.entries(Handler) but returns a Future of the asynchronous result |
ReadStream<Map.Entry<K,V>> |
entryStream()
Get the entries of the map as a
ReadStream. |
Future<V> |
get(K k)
Same as
#get(K, Handler) but returns a Future of the asynchronous result |
Future<Set<K>> |
keys()
Same as
AsyncMap.keys(Handler) but returns a Future of the asynchronous result |
ReadStream<K> |
keyStream()
Get the keys of the map as a
ReadStream. |
Future<Void> |
put(K k,
V v)
Same as
#put(K, V, Handler) but returns a Future of the asynchronous result |
Future<Void> |
put(K k,
V v,
long ttl)
Same as
#put(K, V, long, Handler) but returns a Future of the asynchronous result |
Future<V> |
putIfAbsent(K k,
V v)
Same as
#putIfAbsent(K, V, Handler) but returns a Future of the asynchronous result |
Future<V> |
putIfAbsent(K k,
V v,
long ttl)
Same as
#putIfAbsent(K, V, long, Handler) but returns a Future of the asynchronous result |
Future<V> |
remove(K k)
Same as
#remove(K, Handler) but returns a Future of the asynchronous result |
Future<Boolean> |
removeIfPresent(K k,
V v)
Same as
#removeIfPresent(K, V, Handler) but returns a Future of the asynchronous result |
Future<V> |
replace(K k,
V v)
Same as
#replace(K, V, Handler) but returns a Future of the asynchronous result |
Future<Boolean> |
replaceIfPresent(K k,
V oldValue,
V newValue)
Same as
#replaceIfPresent(K, V, V, Handler) but returns a Future of the asynchronous result |
Future<Integer> |
size()
Same as
AsyncMap.size(Handler) but returns a Future of the asynchronous result |
Future<List<V>> |
values()
Same as
AsyncMap.values(Handler) but returns a Future of the asynchronous result |
ReadStream<V> |
valueStream()
Get the values of the map as a
ReadStream. |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitclear, entries, get, keys, put, put, putIfAbsent, putIfAbsent, remove, removeIfPresent, replace, replaceIfPresent, size, valuesunwrappublic InfinispanAsyncMapImpl(VertxInternal vertx, org.infinispan.Cache<byte[],byte[]> cache)
public Future<V> get(K k)
AsyncMap#get(K, Handler) but returns a Future of the asynchronous resultpublic Future<Void> put(K k, V v)
AsyncMap#put(K, V, Handler) but returns a Future of the asynchronous resultpublic Future<Void> put(K k, V v, long ttl)
AsyncMap#put(K, V, long, Handler) but returns a Future of the asynchronous resultpublic Future<V> putIfAbsent(K k, V v)
AsyncMap#putIfAbsent(K, V, Handler) but returns a Future of the asynchronous resultputIfAbsent in interface AsyncMap<K,V>public Future<V> putIfAbsent(K k, V v, long ttl)
AsyncMap#putIfAbsent(K, V, long, Handler) but returns a Future of the asynchronous resultputIfAbsent in interface AsyncMap<K,V>public Future<V> remove(K k)
AsyncMap#remove(K, Handler) but returns a Future of the asynchronous resultpublic Future<Boolean> removeIfPresent(K k, V v)
AsyncMap#removeIfPresent(K, V, Handler) but returns a Future of the asynchronous resultremoveIfPresent in interface AsyncMap<K,V>public Future<V> replace(K k, V v)
AsyncMap#replace(K, V, Handler) but returns a Future of the asynchronous resultpublic Future<Boolean> replaceIfPresent(K k, V oldValue, V newValue)
AsyncMap#replaceIfPresent(K, V, V, Handler) but returns a Future of the asynchronous resultreplaceIfPresent in interface AsyncMap<K,V>public Future<Void> clear()
AsyncMapAsyncMap.clear(Handler) but returns a Future of the asynchronous resultpublic Future<Integer> size()
AsyncMapAsyncMap.size(Handler) but returns a Future of the asynchronous resultpublic Future<Set<K>> keys()
AsyncMapAsyncMap.keys(Handler) but returns a Future of the asynchronous resultpublic Future<List<V>> values()
AsyncMapAsyncMap.values(Handler) but returns a Future of the asynchronous resultpublic Future<Map<K,V>> entries()
AsyncMapAsyncMap.entries(Handler) but returns a Future of the asynchronous resultpublic ReadStream<K> keyStream()
InfinispanAsyncMapReadStream.
The stream will be automatically closed if it fails or ends.
Otherwise you must set a null data handler after usage to avoid leaking resources.
keyStream in interface InfinispanAsyncMap<K,V>public ReadStream<V> valueStream()
InfinispanAsyncMapReadStream.
The stream will be automatically closed if it fails or ends.
Otherwise you must set a null data handler after usage to avoid leaking resources.
valueStream in interface InfinispanAsyncMap<K,V>public ReadStream<Map.Entry<K,V>> entryStream()
InfinispanAsyncMapReadStream.
The stream will be automatically closed if it fails or ends.
Otherwise you must set a null data handler after usage to avoid leaking resources.
entryStream in interface InfinispanAsyncMap<K,V>Copyright © 2021. All rights reserved.