public class Counter extends Object
NOTE: This class has been automatically generated from the
original
non RX-ified interface using Vert.x codegen.Modifier and Type | Field and Description |
---|---|
static TypeArg<Counter> |
__TYPE_ARG |
Constructor and Description |
---|
Counter(io.vertx.core.shareddata.Counter delegate) |
Counter(Object delegate) |
Modifier and Type | Method and Description |
---|---|
io.reactivex.rxjava3.core.Single<Long> |
addAndGet(long value)
Add the value to the counter atomically and return the new count
|
io.reactivex.rxjava3.core.Single<Boolean> |
compareAndSet(long expected,
long value)
Set the counter to the specified value only if the current value is the expectec value.
|
io.reactivex.rxjava3.core.Single<Long> |
decrementAndGet()
Decrement the counter atomically and return the new count
|
boolean |
equals(Object o) |
io.reactivex.rxjava3.core.Single<Long> |
get()
Get the current value of the counter
|
io.reactivex.rxjava3.core.Single<Long> |
getAndAdd(long value)
Add the value to the counter atomically and return the value before the add
|
io.reactivex.rxjava3.core.Single<Long> |
getAndIncrement()
Increment the counter atomically and return the value before the increment.
|
io.vertx.core.shareddata.Counter |
getDelegate() |
int |
hashCode() |
io.reactivex.rxjava3.core.Single<Long> |
incrementAndGet()
Increment the counter atomically and return the new count
|
static Counter |
newInstance(io.vertx.core.shareddata.Counter arg) |
io.reactivex.rxjava3.core.Single<Long> |
rxAddAndGet(long value)
Add the value to the counter atomically and return the new count
|
io.reactivex.rxjava3.core.Single<Boolean> |
rxCompareAndSet(long expected,
long value)
Set the counter to the specified value only if the current value is the expectec value.
|
io.reactivex.rxjava3.core.Single<Long> |
rxDecrementAndGet()
Decrement the counter atomically and return the new count
|
io.reactivex.rxjava3.core.Single<Long> |
rxGet()
Get the current value of the counter
|
io.reactivex.rxjava3.core.Single<Long> |
rxGetAndAdd(long value)
Add the value to the counter atomically and return the value before the add
|
io.reactivex.rxjava3.core.Single<Long> |
rxGetAndIncrement()
Increment the counter atomically and return the value before the increment.
|
io.reactivex.rxjava3.core.Single<Long> |
rxIncrementAndGet()
Increment the counter atomically and return the new count
|
String |
toString() |
public Counter(io.vertx.core.shareddata.Counter delegate)
public Counter(Object delegate)
public io.vertx.core.shareddata.Counter getDelegate()
public io.reactivex.rxjava3.core.Single<Long> get()
public io.reactivex.rxjava3.core.Single<Long> rxGet()
public io.reactivex.rxjava3.core.Single<Long> incrementAndGet()
public io.reactivex.rxjava3.core.Single<Long> rxIncrementAndGet()
public io.reactivex.rxjava3.core.Single<Long> getAndIncrement()
public io.reactivex.rxjava3.core.Single<Long> rxGetAndIncrement()
public io.reactivex.rxjava3.core.Single<Long> decrementAndGet()
public io.reactivex.rxjava3.core.Single<Long> rxDecrementAndGet()
public io.reactivex.rxjava3.core.Single<Long> addAndGet(long value)
value
- the value to addpublic io.reactivex.rxjava3.core.Single<Long> rxAddAndGet(long value)
value
- the value to addpublic io.reactivex.rxjava3.core.Single<Long> getAndAdd(long value)
value
- the value to addpublic io.reactivex.rxjava3.core.Single<Long> rxGetAndAdd(long value)
value
- the value to addpublic io.reactivex.rxjava3.core.Single<Boolean> compareAndSet(long expected, long value)
expected
- the expected valuevalue
- the new valuepublic io.reactivex.rxjava3.core.Single<Boolean> rxCompareAndSet(long expected, long value)
expected
- the expected valuevalue
- the new valuepublic static Counter newInstance(io.vertx.core.shareddata.Counter arg)
Copyright © 2021 Eclipse. All rights reserved.