class AsyncMap[K, V] extends AnyRef
An asynchronous map.
io.vertx.scala.core.shareddata.AsyncMap does not allow null
to be used as a key or value.
- Alphabetic
- By Inheritance
- AsyncMap
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
- new AsyncMap(_asJava: AnyRef)(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[K], arg1: scala.reflect.api.JavaUniverse.TypeTag[V])
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
- def asJava: AnyRef
-
def
clear(resultHandler: Handler[AsyncResult[Unit]]): Unit
Clear all entries in the map * @param resultHandler called on completion
-
def
clearFuture(): scala.concurrent.Future[Unit]
Like clear but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
def
get(k: K, resultHandler: Handler[AsyncResult[Option[V]]]): Unit
Get a value from the map, asynchronously.
Get a value from the map, asynchronously. * @param k the key
- resultHandler
- this will be called some time later with the async result.
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
getFuture(k: K): scala.concurrent.Future[Option[V]]
Like get but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
def
put(k: K, v: V, ttl: Long, completionHandler: Handler[AsyncResult[Unit]]): Unit
Like io.vertx.scala.core.shareddata.AsyncMap#put but specifying a time to live for the entry.
Like io.vertx.scala.core.shareddata.AsyncMap#put but specifying a time to live for the entry. Entry will expire and get evicted after the ttl. * @param k the key
- v
the value
- ttl
The time to live (in ms) for the entry
- completionHandler
the handler
-
def
put(k: K, v: V, completionHandler: Handler[AsyncResult[Unit]]): Unit
Put a value in the map, asynchronously.
Put a value in the map, asynchronously. * @param k the key
- v
the value
- completionHandler
- this will be called some time later to signify the value has been put
-
def
putFuture(k: K, v: V, ttl: Long): scala.concurrent.Future[Unit]
Like put but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
putFuture(k: K, v: V): scala.concurrent.Future[Unit]
Like put but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
putIfAbsent(k: K, v: V, ttl: Long, completionHandler: Handler[AsyncResult[Option[V]]]): Unit
Link io.vertx.scala.core.shareddata.AsyncMap#putIfAbsent but specifying a time to live for the entry.
Link io.vertx.scala.core.shareddata.AsyncMap#putIfAbsent but specifying a time to live for the entry. Entry will expire and get evicted after the ttl. * @param k the key
- v
the value
- ttl
The time to live (in ms) for the entry
- completionHandler
the handler
-
def
putIfAbsent(k: K, v: V, completionHandler: Handler[AsyncResult[Option[V]]]): Unit
Put the entry only if there is no entry with the key already present.
Put the entry only if there is no entry with the key already present. If key already present then the existing value will be returned to the handler, otherwise null. * @param k the key
- v
the value
- completionHandler
the handler
-
def
putIfAbsentFuture(k: K, v: V, ttl: Long): scala.concurrent.Future[Option[V]]
Like putIfAbsent but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
putIfAbsentFuture(k: K, v: V): scala.concurrent.Future[Option[V]]
Like putIfAbsent but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
remove(k: K, resultHandler: Handler[AsyncResult[Option[V]]]): Unit
Remove a value from the map, asynchronously.
Remove a value from the map, asynchronously. * @param k the key
- resultHandler
- this will be called some time later to signify the value has been removed
-
def
removeFuture(k: K): scala.concurrent.Future[Option[V]]
Like remove but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
removeIfPresent(k: K, v: V, resultHandler: Handler[AsyncResult[Boolean]]): Unit
Remove a value from the map, only if entry already exists with same value.
Remove a value from the map, only if entry already exists with same value. * @param k the key
- v
the value
- resultHandler
- this will be called some time later to signify the value has been removed
-
def
removeIfPresentFuture(k: K, v: V): scala.concurrent.Future[Boolean]
Like removeIfPresent but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
replace(k: K, v: V, resultHandler: Handler[AsyncResult[Option[V]]]): Unit
Replace the entry only if it is currently mapped to some value * @param k the key
Replace the entry only if it is currently mapped to some value * @param k the key
- v
the new value
- resultHandler
the result handler will be passed the previous value
-
def
replaceFuture(k: K, v: V): scala.concurrent.Future[Option[V]]
Like replace but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
replaceIfPresent(k: K, oldValue: V, newValue: V, resultHandler: Handler[AsyncResult[Boolean]]): Unit
Replace the entry only if it is currently mapped to a specific value * @param k the key
Replace the entry only if it is currently mapped to a specific value * @param k the key
- oldValue
the existing value
- newValue
the new value
- resultHandler
the result handler
-
def
replaceIfPresentFuture(k: K, oldValue: V, newValue: V): scala.concurrent.Future[Boolean]
Like replaceIfPresent but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
size(resultHandler: Handler[AsyncResult[Int]]): Unit
Provide the number of entries in the map * @param resultHandler handler which will receive the number of entries
-
def
sizeFuture(): scala.concurrent.Future[Int]
Like size but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )