public class AsyncMap<K,V> extends Object
Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<AsyncMap> |
__TYPE_ARG |
io.vertx.lang.rx.TypeArg<K> |
__typeArg_0 |
io.vertx.lang.rx.TypeArg<V> |
__typeArg_1 |
Constructor and Description |
---|
AsyncMap(AsyncMap delegate) |
AsyncMap(Object delegate,
io.vertx.lang.rx.TypeArg<K> typeArg_0,
io.vertx.lang.rx.TypeArg<V> typeArg_1) |
Modifier and Type | Method and Description |
---|---|
void |
clear(Handler<AsyncResult<Void>> resultHandler)
Clear all entries in the map
|
Observable<Void> |
clearObservable()
Deprecated.
use
rxClear() instead |
boolean |
equals(Object o) |
void |
get(K k,
Handler<AsyncResult<V>> resultHandler)
Get a value from the map, asynchronously.
|
AsyncMap |
getDelegate() |
Observable<V> |
getObservable(K k)
Deprecated.
use
rxGet(K) instead |
int |
hashCode() |
static <K,V> AsyncMap<K,V> |
newInstance(AsyncMap arg) |
static <K,V> AsyncMap<K,V> |
newInstance(AsyncMap arg,
io.vertx.lang.rx.TypeArg<K> __typeArg_K,
io.vertx.lang.rx.TypeArg<V> __typeArg_V) |
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 time to live for the entry. |
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 time to live for the entry. |
Observable<V> |
putIfAbsentObservable(K k,
V v)
Deprecated.
use
rxPutIfAbsent(K, V) instead |
Observable<V> |
putIfAbsentObservable(K k,
V v,
long ttl)
Deprecated.
use
rxPutIfAbsent(K, V) instead |
Observable<Void> |
putObservable(K k,
V v)
Deprecated.
use
rxPut(K, V) instead |
Observable<Void> |
putObservable(K k,
V v,
long ttl)
Deprecated.
use
rxPut(K, V) instead |
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)
Deprecated.
use
rxRemoveIfPresent(K, V) instead |
Observable<V> |
removeObservable(K k)
Deprecated.
use
rxRemove(K) instead |
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)
Deprecated.
use
rxReplaceIfPresent(K, V, V) instead |
Observable<V> |
replaceObservable(K k,
V v)
Deprecated.
use
rxReplace(K, V) instead |
Single<Void> |
rxClear()
Clear all entries in the map
|
Single<V> |
rxGet(K k)
Get a value from the map, asynchronously.
|
Single<Void> |
rxPut(K k,
V v)
Put a value in the map, asynchronously.
|
Single<Void> |
rxPut(K k,
V v,
long ttl)
Like
put(K, V, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>) but specifying a time to live for the entry. |
Single<V> |
rxPutIfAbsent(K k,
V v)
Put the entry only if there is no entry with the key already present.
|
Single<V> |
rxPutIfAbsent(K k,
V v,
long ttl)
Link
putIfAbsent(K, V, io.vertx.core.Handler<io.vertx.core.AsyncResult<V>>) but specifying a time to live for the entry. |
Single<V> |
rxRemove(K k)
Remove a value from the map, asynchronously.
|
Single<Boolean> |
rxRemoveIfPresent(K k,
V v)
Remove a value from the map, only if entry already exists with same value.
|
Single<V> |
rxReplace(K k,
V v)
Replace the entry only if it is currently mapped to some value
|
Single<Boolean> |
rxReplaceIfPresent(K k,
V oldValue,
V newValue)
Replace the entry only if it is currently mapped to a specific value
|
Single<Integer> |
rxSize()
Provide the number of entries in the map
|
void |
size(Handler<AsyncResult<Integer>> resultHandler)
Provide the number of entries in the map
|
Observable<Integer> |
sizeObservable()
Deprecated.
use
rxSize() instead |
String |
toString() |
public static final io.vertx.lang.rx.TypeArg<AsyncMap> __TYPE_ARG
public final io.vertx.lang.rx.TypeArg<K> __typeArg_0
public final io.vertx.lang.rx.TypeArg<V> __typeArg_1
public AsyncMap(AsyncMap delegate)
public AsyncMap getDelegate()
public void get(K k, Handler<AsyncResult<V>> resultHandler)
k
- the keyresultHandler
- - this will be called some time later with the async result.@Deprecated public Observable<V> getObservable(K k)
rxGet(K)
insteadk
- the keypublic Single<V> rxGet(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 put@Deprecated public Observable<Void> putObservable(K k, V v)
rxPut(K, V)
insteadk
- the keyv
- the valuepublic Single<Void> rxPut(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 time to live for the entry. Entry will expire and get evicted after the
ttl.k
- the keyv
- the valuettl
- The time to live (in ms) for the entrycompletionHandler
- the handler@Deprecated public Observable<Void> putObservable(K k, V v, long ttl)
rxPut(K, V)
insteadput(K, V, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>)
but specifying a time to live for the entry. Entry will expire and get evicted after the
ttl.k
- the keyv
- the valuettl
- The time to live (in ms) for the entrypublic Single<Void> rxPut(K k, V v, long ttl)
put(K, V, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>)
but specifying a time to live for the entry. Entry will expire and get evicted after the
ttl.k
- 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 handler@Deprecated public Observable<V> putIfAbsentObservable(K k, V v)
rxPutIfAbsent(K, V)
insteadk
- the keyv
- the valuepublic Single<V> rxPutIfAbsent(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 time to live for the entry. Entry will expire and get evicted
after the ttl.k
- the keyv
- the valuettl
- The time to live (in ms) for the entrycompletionHandler
- the handler@Deprecated public Observable<V> putIfAbsentObservable(K k, V v, long ttl)
rxPutIfAbsent(K, V)
insteadputIfAbsent(K, V, io.vertx.core.Handler<io.vertx.core.AsyncResult<V>>)
but specifying a time to live for the entry. Entry will expire and get evicted
after the ttl.k
- the keyv
- the valuettl
- The time to live (in ms) for the entrypublic Single<V> rxPutIfAbsent(K k, V v, long ttl)
putIfAbsent(K, V, io.vertx.core.Handler<io.vertx.core.AsyncResult<V>>)
but specifying a time to live for the entry. Entry will expire and get evicted
after the ttl.k
- 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 removed@Deprecated public Observable<V> removeObservable(K k)
rxRemove(K)
insteadk
- the keypublic Single<V> rxRemove(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 removed@Deprecated public Observable<Boolean> removeIfPresentObservable(K k, V v)
rxRemoveIfPresent(K, V)
insteadk
- the keyv
- the valuepublic Single<Boolean> rxRemoveIfPresent(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 value@Deprecated public Observable<V> replaceObservable(K k, V v)
rxReplace(K, V)
insteadk
- the keyv
- the new valuepublic Single<V> rxReplace(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 handler@Deprecated public Observable<Boolean> replaceIfPresentObservable(K k, V oldValue, V newValue)
rxReplaceIfPresent(K, V, V)
insteadk
- the keyoldValue
- the existing valuenewValue
- the new valuepublic Single<Boolean> rxReplaceIfPresent(K k, V oldValue, V newValue)
k
- the keyoldValue
- the existing valuenewValue
- the new valuepublic void clear(Handler<AsyncResult<Void>> resultHandler)
resultHandler
- called on completion@Deprecated public Observable<Void> clearObservable()
rxClear()
insteadpublic void size(Handler<AsyncResult<Integer>> resultHandler)
resultHandler
- handler which will receive the number of entries@Deprecated public Observable<Integer> sizeObservable()
rxSize()
insteadCopyright © 2023 Eclipse. All rights reserved.