Modifier and Type | Method and Description |
---|---|
void |
clear(Handler<AsyncResult<Void>> resultHandler)
Clear all entries in the map
|
Observable<Void> |
clearObservable()
Clear all entries in the map
|
void |
get(K k,
Handler<AsyncResult<V>> resultHandler)
Get a value from the map, asynchronously.
|
Object |
getDelegate() |
Observable<V> |
getObservable(K k)
Get a value from the map, asynchronously.
|
static <K,V> AsyncMap |
newInstance(AsyncMap arg) |
void |
put(K k,
V v,
Handler<AsyncResult<Void>> completionHandler)
Put a value in the map, asynchronously.
|
void |
put(K k,
V v,
long ttl,
Handler<AsyncResult<Void>> completionHandler)
Like
put(K, V, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>) but specifying a timeout. |
void |
putIfAbsent(K k,
V v,
Handler<AsyncResult<V>> completionHandler)
Put the entry only if there is no entry with the key already present.
|
void |
putIfAbsent(K k,
V v,
long ttl,
Handler<AsyncResult<V>> completionHandler)
Link
putIfAbsent(K, V, io.vertx.core.Handler<io.vertx.core.AsyncResult<V>>) but specifying a timeout. |
Observable<V> |
putIfAbsentObservable(K k,
V v)
Put the entry only if there is no entry with the key already present.
|
Observable<V> |
putIfAbsentObservable(K k,
V v,
long ttl)
Link
putIfAbsent(K, V, io.vertx.core.Handler<io.vertx.core.AsyncResult<V>>) but specifying a timeout. |
Observable<Void> |
putObservable(K k,
V v)
Put a value in the map, asynchronously.
|
Observable<Void> |
putObservable(K k,
V v,
long ttl)
Like
put(K, V, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>) but specifying a timeout. |
void |
remove(K k,
Handler<AsyncResult<V>> resultHandler)
Remove a value from the map, asynchronously.
|
void |
removeIfPresent(K k,
V v,
Handler<AsyncResult<Boolean>> resultHandler)
Remove a value from the map, only if entry already exists with same value.
|
Observable<Boolean> |
removeIfPresentObservable(K k,
V v)
Remove a value from the map, only if entry already exists with same value.
|
Observable<V> |
removeObservable(K k)
Remove a value from the map, asynchronously.
|
void |
replace(K k,
V v,
Handler<AsyncResult<V>> resultHandler)
Replace the entry only if it is currently mapped to some value
|
void |
replaceIfPresent(K k,
V oldValue,
V newValue,
Handler<AsyncResult<Boolean>> resultHandler)
Replace the entry only if it is currently mapped to a specific value
|
Observable<Boolean> |
replaceIfPresentObservable(K k,
V oldValue,
V newValue)
Replace the entry only if it is currently mapped to a specific value
|
Observable<V> |
replaceObservable(K k,
V v)
Replace the entry only if it is currently mapped to some value
|
void |
size(Handler<AsyncResult<Integer>> resultHandler)
Provide the number of entries in the map
|
Observable<Integer> |
sizeObservable()
Provide the number of entries in the map
|
public AsyncMap(AsyncMap delegate)
public Object getDelegate()
public void get(K k, Handler<AsyncResult<V>> resultHandler)
k
- the keyresultHandler
- - this will be called some time later with the async result.public Observable<V> getObservable(K k)
k
- the keypublic void put(K k, V v, Handler<AsyncResult<Void>> completionHandler)
k
- the keyv
- the valuecompletionHandler
- - this will be called some time later to signify the value has been putpublic Observable<Void> putObservable(K k, V v)
k
- the keyv
- the valuepublic void put(K k, V v, long ttl, Handler<AsyncResult<Void>> completionHandler)
put(K, V, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>)
but specifying a timeout. If the value cannot be put within the timeout a
failure will be passed to the handlerk
- the keyv
- the valuettl
- The time to live (in ms) for the entrycompletionHandler
- the handlerpublic Observable<Void> putObservable(K k, V v, long ttl)
put(K, V, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>)
but specifying a timeout. If the value cannot be put within the timeout a
failure will be passed to the handlerk
- the keyv
- the valuettl
- The time to live (in ms) for the entrypublic void putIfAbsent(K k, V v, Handler<AsyncResult<V>> completionHandler)
k
- the keyv
- the valuecompletionHandler
- the handlerpublic Observable<V> putIfAbsentObservable(K k, V v)
k
- the keyv
- the valuepublic void putIfAbsent(K k, V v, long ttl, Handler<AsyncResult<V>> completionHandler)
putIfAbsent(K, V, io.vertx.core.Handler<io.vertx.core.AsyncResult<V>>)
but specifying a timeout. If the value cannot be put within the timeout a
failure will be passed to the handlerk
- the keyv
- the valuettl
- The time to live (in ms) for the entrycompletionHandler
- the handlerpublic Observable<V> putIfAbsentObservable(K k, V v, long ttl)
putIfAbsent(K, V, io.vertx.core.Handler<io.vertx.core.AsyncResult<V>>)
but specifying a timeout. If the value cannot be put within the timeout a
failure will be passed to the handlerk
- the keyv
- the valuettl
- The time to live (in ms) for the entrypublic void remove(K k, Handler<AsyncResult<V>> resultHandler)
k
- the keyresultHandler
- - this will be called some time later to signify the value has been removedpublic Observable<V> removeObservable(K k)
k
- the keypublic void removeIfPresent(K k, V v, Handler<AsyncResult<Boolean>> resultHandler)
k
- the keyv
- the valueresultHandler
- - this will be called some time later to signify the value has been removedpublic Observable<Boolean> removeIfPresentObservable(K k, V v)
k
- the keyv
- the valuepublic void replace(K k, V v, Handler<AsyncResult<V>> resultHandler)
k
- the keyv
- the new valueresultHandler
- the result handler will be passed the previous valuepublic Observable<V> replaceObservable(K k, V v)
k
- the keyv
- the new valuepublic void replaceIfPresent(K k, V oldValue, V newValue, Handler<AsyncResult<Boolean>> resultHandler)
k
- the keyoldValue
- the existing valuenewValue
- the new valueresultHandler
- the result handlerpublic Observable<Boolean> replaceIfPresentObservable(K k, V oldValue, V newValue)
k
- the keyoldValue
- the existing valuenewValue
- the new valuepublic void clear(Handler<AsyncResult<Void>> resultHandler)
resultHandler
- called on completionpublic Observable<Void> clearObservable()
public void size(Handler<AsyncResult<Integer>> resultHandler)
resultHandler
- handler which will receive the number of entriespublic Observable<Integer> sizeObservable()
Copyright © 2016. All rights reserved.