Modifier and Type | Field and Description |
---|---|
static TypeArg<AsyncMap> |
__TYPE_ARG |
TypeArg<K> |
__typeArg_0 |
TypeArg<V> |
__typeArg_1 |
Constructor and Description |
---|
AsyncMap(io.vertx.core.shareddata.AsyncMap delegate) |
AsyncMap(Object delegate,
TypeArg<K> typeArg_0,
TypeArg<V> typeArg_1) |
Modifier and Type | Method and Description |
---|---|
io.reactivex.rxjava3.core.Completable |
clear()
Clear all entries in the map
|
boolean |
equals(Object o) |
io.reactivex.rxjava3.core.Maybe<V> |
get(K k)
Get a value from the map, asynchronously.
|
io.vertx.core.shareddata.AsyncMap |
getDelegate() |
int |
hashCode() |
static <K,V> AsyncMap<K,V> |
newInstance(io.vertx.core.shareddata.AsyncMap arg) |
static <K,V> AsyncMap<K,V> |
newInstance(io.vertx.core.shareddata.AsyncMap arg,
TypeArg<K> __typeArg_K,
TypeArg<V> __typeArg_V) |
io.reactivex.rxjava3.core.Completable |
put(K k,
V v)
Put a value in the map, asynchronously.
|
io.reactivex.rxjava3.core.Completable |
put(K k,
V v,
long ttl)
Like
put(K, V) but specifying a time to live for the entry. |
io.reactivex.rxjava3.core.Maybe<V> |
putIfAbsent(K k,
V v)
Put the entry only if there is no entry with the key already present.
|
io.reactivex.rxjava3.core.Maybe<V> |
putIfAbsent(K k,
V v,
long ttl)
Link
putIfAbsent(K, V) but specifying a time to live for the entry. |
io.reactivex.rxjava3.core.Maybe<V> |
remove(K k)
Remove a value from the map, asynchronously.
|
io.reactivex.rxjava3.core.Single<Boolean> |
removeIfPresent(K k,
V v)
Remove a value from the map, only if entry already exists with same value.
|
io.reactivex.rxjava3.core.Maybe<V> |
replace(K k,
V v)
Replace the entry only if it is currently mapped to some value
|
io.reactivex.rxjava3.core.Maybe<V> |
replace(K k,
V v,
long ttl)
Replace the entry only if it is currently mapped to some value
|
io.reactivex.rxjava3.core.Single<Boolean> |
replaceIfPresent(K k,
V oldValue,
V newValue)
Replace the entry only if it is currently mapped to a specific value
|
io.reactivex.rxjava3.core.Single<Boolean> |
replaceIfPresent(K k,
V oldValue,
V newValue,
long ttl)
Replace the entry only if it is currently mapped to a specific value
|
io.reactivex.rxjava3.core.Completable |
rxClear()
Clear all entries in the map
|
io.reactivex.rxjava3.core.Maybe<V> |
rxGet(K k)
Get a value from the map, asynchronously.
|
io.reactivex.rxjava3.core.Completable |
rxPut(K k,
V v)
Put a value in the map, asynchronously.
|
io.reactivex.rxjava3.core.Completable |
rxPut(K k,
V v,
long ttl)
Like
put(K, V) but specifying a time to live for the entry. |
io.reactivex.rxjava3.core.Maybe<V> |
rxPutIfAbsent(K k,
V v)
Put the entry only if there is no entry with the key already present.
|
io.reactivex.rxjava3.core.Maybe<V> |
rxPutIfAbsent(K k,
V v,
long ttl)
Link
putIfAbsent(K, V) but specifying a time to live for the entry. |
io.reactivex.rxjava3.core.Maybe<V> |
rxRemove(K k)
Remove a value from the map, asynchronously.
|
io.reactivex.rxjava3.core.Single<Boolean> |
rxRemoveIfPresent(K k,
V v)
Remove a value from the map, only if entry already exists with same value.
|
io.reactivex.rxjava3.core.Maybe<V> |
rxReplace(K k,
V v)
Replace the entry only if it is currently mapped to some value
|
io.reactivex.rxjava3.core.Maybe<V> |
rxReplace(K k,
V v,
long ttl)
Replace the entry only if it is currently mapped to some value
|
io.reactivex.rxjava3.core.Single<Boolean> |
rxReplaceIfPresent(K k,
V oldValue,
V newValue)
Replace the entry only if it is currently mapped to a specific value
|
io.reactivex.rxjava3.core.Single<Boolean> |
rxReplaceIfPresent(K k,
V oldValue,
V newValue,
long ttl)
Replace the entry only if it is currently mapped to a specific value
|
io.reactivex.rxjava3.core.Single<Integer> |
rxSize()
Provide the number of entries in the map
|
io.reactivex.rxjava3.core.Single<Integer> |
size()
Provide the number of entries in the map
|
String |
toString() |
public io.vertx.core.shareddata.AsyncMap getDelegate()
public io.reactivex.rxjava3.core.Maybe<V> get(K k)
k
- the keypublic io.reactivex.rxjava3.core.Maybe<V> rxGet(K k)
k
- the keypublic io.reactivex.rxjava3.core.Completable put(K k, V v)
k
- the keyv
- the valuepublic io.reactivex.rxjava3.core.Completable rxPut(K k, V v)
k
- the keyv
- the valuepublic io.reactivex.rxjava3.core.Completable put(K k, V v, long ttl)
put(K, 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 io.reactivex.rxjava3.core.Completable rxPut(K k, V v, long ttl)
put(K, 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 io.reactivex.rxjava3.core.Maybe<V> putIfAbsent(K k, V v)
k
- the keyv
- the valuepublic io.reactivex.rxjava3.core.Maybe<V> rxPutIfAbsent(K k, V v)
k
- the keyv
- the valuepublic io.reactivex.rxjava3.core.Maybe<V> putIfAbsent(K k, V v, long ttl)
putIfAbsent(K, 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 io.reactivex.rxjava3.core.Maybe<V> rxPutIfAbsent(K k, V v, long ttl)
putIfAbsent(K, 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 io.reactivex.rxjava3.core.Maybe<V> remove(K k)
k
- the keypublic io.reactivex.rxjava3.core.Maybe<V> rxRemove(K k)
k
- the keypublic io.reactivex.rxjava3.core.Single<Boolean> removeIfPresent(K k, V v)
k
- the keyv
- the valuepublic io.reactivex.rxjava3.core.Single<Boolean> rxRemoveIfPresent(K k, V v)
k
- the keyv
- the valuepublic io.reactivex.rxjava3.core.Maybe<V> replace(K k, V v)
k
- the keyv
- the new valuepublic io.reactivex.rxjava3.core.Maybe<V> rxReplace(K k, V v)
k
- the keyv
- the new valuepublic io.reactivex.rxjava3.core.Maybe<V> replace(K k, V v, long ttl)
k
- the keyv
- the new valuettl
- The time to live (in ms) for the entrypublic io.reactivex.rxjava3.core.Maybe<V> rxReplace(K k, V v, long ttl)
k
- the keyv
- the new valuettl
- The time to live (in ms) for the entrypublic io.reactivex.rxjava3.core.Single<Boolean> replaceIfPresent(K k, V oldValue, V newValue)
k
- the keyoldValue
- the existing valuenewValue
- the new valuepublic io.reactivex.rxjava3.core.Single<Boolean> rxReplaceIfPresent(K k, V oldValue, V newValue)
k
- the keyoldValue
- the existing valuenewValue
- the new valuepublic io.reactivex.rxjava3.core.Single<Boolean> replaceIfPresent(K k, V oldValue, V newValue, long ttl)
k
- the keyoldValue
- the existing valuenewValue
- the new valuettl
- The time to live (in ms) for the entrypublic io.reactivex.rxjava3.core.Single<Boolean> rxReplaceIfPresent(K k, V oldValue, V newValue, long ttl)
k
- the keyoldValue
- the existing valuenewValue
- the new valuettl
- The time to live (in ms) for the entrypublic io.reactivex.rxjava3.core.Completable clear()
public io.reactivex.rxjava3.core.Completable rxClear()
public io.reactivex.rxjava3.core.Single<Integer> size()
public io.reactivex.rxjava3.core.Single<Integer> rxSize()
public static <K,V> AsyncMap<K,V> newInstance(io.vertx.core.shareddata.AsyncMap arg)
Copyright © 2021 Eclipse. All rights reserved.