| Modifier and Type | Field and Description | 
|---|---|
static io.vertx.lang.rx.TypeArg<Counter> | 
__TYPE_ARG  | 
| Constructor and Description | 
|---|
Counter(Counter delegate)  | 
Counter(Object delegate)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
addAndGet(long value,
         Handler<AsyncResult<Long>> resultHandler)
Add the value to the counter atomically and return the new count 
 | 
Observable<Long> | 
addAndGetObservable(long value)
Deprecated. 
 
use  
rxAddAndGet(long) instead | 
void | 
compareAndSet(long expected,
             long value,
             Handler<AsyncResult<Boolean>> resultHandler)
Set the counter to the specified value only if the current value is the expectec value. 
 | 
Observable<Boolean> | 
compareAndSetObservable(long expected,
                       long value)
Deprecated. 
 
use  
rxCompareAndSet(long, long) instead | 
void | 
decrementAndGet(Handler<AsyncResult<Long>> resultHandler)
Decrement the counter atomically and return the new count 
 | 
Observable<Long> | 
decrementAndGetObservable()
Deprecated. 
 
use  
rxDecrementAndGet() instead | 
boolean | 
equals(Object o)  | 
void | 
get(Handler<AsyncResult<Long>> resultHandler)
Get the current value of the counter 
 | 
void | 
getAndAdd(long value,
         Handler<AsyncResult<Long>> resultHandler)
Add the value to the counter atomically and return the value before the add 
 | 
Observable<Long> | 
getAndAddObservable(long value)
Deprecated. 
 
use  
rxGetAndAdd(long) instead | 
void | 
getAndIncrement(Handler<AsyncResult<Long>> resultHandler)
Increment the counter atomically and return the value before the increment. 
 | 
Observable<Long> | 
getAndIncrementObservable()
Deprecated. 
 
use  
rxGetAndIncrement() instead | 
Counter | 
getDelegate()  | 
Observable<Long> | 
getObservable()
Deprecated. 
 
use  
rxGet() instead | 
int | 
hashCode()  | 
void | 
incrementAndGet(Handler<AsyncResult<Long>> resultHandler)
Increment the counter atomically and return the new count 
 | 
Observable<Long> | 
incrementAndGetObservable()
Deprecated. 
 
use  
rxIncrementAndGet() instead | 
static Counter | 
newInstance(Counter arg)  | 
Single<Long> | 
rxAddAndGet(long value)
Add the value to the counter atomically and return the new count 
 | 
Single<Boolean> | 
rxCompareAndSet(long expected,
               long value)
Set the counter to the specified value only if the current value is the expectec value. 
 | 
Single<Long> | 
rxDecrementAndGet()
Decrement the counter atomically and return the new count 
 | 
Single<Long> | 
rxGet()
Get the current value of the counter 
 | 
Single<Long> | 
rxGetAndAdd(long value)
Add the value to the counter atomically and return the value before the add 
 | 
Single<Long> | 
rxGetAndIncrement()
Increment the counter atomically and return the value before the increment. 
 | 
Single<Long> | 
rxIncrementAndGet()
Increment the counter atomically and return the new count 
 | 
String | 
toString()  | 
public static final io.vertx.lang.rx.TypeArg<Counter> __TYPE_ARG
public Counter getDelegate()
public void get(Handler<AsyncResult<Long>> resultHandler)
resultHandler - handler which will be passed the value@Deprecated public Observable<Long> getObservable()
rxGet() insteadpublic void incrementAndGet(Handler<AsyncResult<Long>> resultHandler)
resultHandler - handler which will be passed the value@Deprecated public Observable<Long> incrementAndGetObservable()
rxIncrementAndGet() insteadpublic Single<Long> rxIncrementAndGet()
public void getAndIncrement(Handler<AsyncResult<Long>> resultHandler)
resultHandler - handler which will be passed the value@Deprecated public Observable<Long> getAndIncrementObservable()
rxGetAndIncrement() insteadpublic Single<Long> rxGetAndIncrement()
public void decrementAndGet(Handler<AsyncResult<Long>> resultHandler)
resultHandler - handler which will be passed the value@Deprecated public Observable<Long> decrementAndGetObservable()
rxDecrementAndGet() insteadpublic Single<Long> rxDecrementAndGet()
public void addAndGet(long value,
                      Handler<AsyncResult<Long>> resultHandler)
value - the value to addresultHandler - handler which will be passed the value@Deprecated public Observable<Long> addAndGetObservable(long value)
rxAddAndGet(long) insteadvalue - the value to addpublic Single<Long> rxAddAndGet(long value)
value - the value to addpublic void getAndAdd(long value,
                      Handler<AsyncResult<Long>> resultHandler)
value - the value to addresultHandler - handler which will be passed the value@Deprecated public Observable<Long> getAndAddObservable(long value)
rxGetAndAdd(long) insteadvalue - the value to addpublic Single<Long> rxGetAndAdd(long value)
value - the value to addpublic void compareAndSet(long expected,
                          long value,
                          Handler<AsyncResult<Boolean>> resultHandler)
expected - the expected valuevalue - the new valueresultHandler - the handler will be passed true on success@Deprecated public Observable<Boolean> compareAndSetObservable(long expected, long value)
rxCompareAndSet(long, long) insteadexpected - the expected valuevalue - the new valuepublic Single<Boolean> rxCompareAndSet(long expected, long value)
expected - the expected valuevalue - the new valueCopyright © 2020 Eclipse. All rights reserved.