open class Counter
An asynchronous counter that can be used to across the cluster to maintain a consistent count.
NOTE: This class has been automatically generated from the io.vertx.core.shareddata.Counter non RX-ified interface using Vert.x codegen.
Counter(: Counter) |
static val __TYPE_ARG: TypeArg<Counter> |
open fun addAndGet(: Long, : Handler<AsyncResult<Long>>): Unit
Add the value to the counter atomically and return the new count |
|
open fun compareAndSet(: Long, : Long, : Handler<AsyncResult<Boolean>>): Unit
Set the counter to the specified value only if the current value is the expectec value. This happens atomically. |
|
open fun decrementAndGet(: Handler<AsyncResult<Long>>): Unit
Decrement the counter atomically and return the new count |
|
open fun equals(: Any?): Boolean |
|
open fun get(: Handler<AsyncResult<Long>>): Unit
Get the current value of the counter |
|
open fun getAndAdd(: Long, : Handler<AsyncResult<Long>>): Unit
Add the value to the counter atomically and return the value before the add |
|
open fun getAndIncrement(: Handler<AsyncResult<Long>>): Unit
Increment the counter atomically and return the value before the increment. |
|
open fun getDelegate(): Counter |
|
open fun hashCode(): Int |
|
open fun incrementAndGet(: Handler<AsyncResult<Long>>): Unit
Increment the counter atomically and return the new count |
|
open static fun newInstance(: Counter): Counter |
|
open fun rxAddAndGet(: Long): Single<Long>
Add the value to the counter atomically and return the new count |
|
open fun rxCompareAndSet(: Long, : Long): Single<Boolean>
Set the counter to the specified value only if the current value is the expectec value. This happens atomically. |
|
open fun rxDecrementAndGet(): Single<Long>
Decrement the counter atomically and return the new count |
|
open fun rxGet(): Single<Long>
Get the current value of the counter |
|
open fun rxGetAndAdd(: Long): Single<Long>
Add the value to the counter atomically and return the value before the add |
|
open fun rxGetAndIncrement(): Single<Long>
Increment the counter atomically and return the value before the increment. |
|
open fun rxIncrementAndGet(): Single<Long>
Increment the counter atomically and return the new count |
|
open fun toString(): String |