Package org.redisson.api
Interface RAtomicDoubleReactive
-
- All Superinterfaces:
RExpirableReactive
,RObjectReactive
public interface RAtomicDoubleReactive extends RExpirableReactive
Reactive interface for AtomicDouble object- Author:
- Nikita Koksharov
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description reactor.core.publisher.Mono<>
addAndGet(double delta)
Atomically adds the given value to the current value.reactor.core.publisher.Mono<>
compareAndSet(double expect, double update)
Atomically sets the value to the given updated value only if the current value==
the expected value.reactor.core.publisher.Mono<>
decrementAndGet()
Atomically decrements the current value by one.reactor.core.publisher.Mono<>
get()
Returns current value.reactor.core.publisher.Mono<>
getAndAdd(double delta)
Atomically adds the given value to the current value.reactor.core.publisher.Mono<>
getAndDecrement()
Atomically decrements by one the current value.reactor.core.publisher.Mono<>
getAndDelete()
Returns and deletes objectreactor.core.publisher.Mono<>
getAndIncrement()
Atomically increments the current value by one.reactor.core.publisher.Mono<>
getAndSet(double newValue)
Atomically sets the given value and returns the old value.reactor.core.publisher.Mono<>
incrementAndGet()
Atomically increments the current value by one.reactor.core.publisher.Mono<>
set(double newValue)
Atomically sets the given value.-
Methods inherited from interface org.redisson.api.RExpirableReactive
clearExpire, expire, expireAt, expireAt, expireAt, remainTimeToLive
-
Methods inherited from interface org.redisson.api.RObjectReactive
addListener, copy, delete, dump, getCodec, getIdleTime, getName, isExists, migrate, move, removeListener, rename, renamenx, restore, restore, restoreAndReplace, restoreAndReplace, sizeInMemory, touch, unlink
-
-
-
-
Method Detail
-
compareAndSet
reactor.core.publisher.Mono<> compareAndSet(double expect, double update)
Atomically sets the value to the given updated value only if the current value==
the expected value.- Parameters:
expect
- the expected valueupdate
- the new value- Returns:
- true if successful; or false if the actual value was not equal to the expected value.
-
addAndGet
reactor.core.publisher.Mono<> addAndGet(double delta)
Atomically adds the given value to the current value.- Parameters:
delta
- the value to add- Returns:
- the updated value
-
decrementAndGet
reactor.core.publisher.Mono<> decrementAndGet()
Atomically decrements the current value by one.- Returns:
- the updated value
-
get
reactor.core.publisher.Mono<> get()
Returns current value.- Returns:
- current value
-
getAndDelete
reactor.core.publisher.Mono<> getAndDelete()
Returns and deletes object- Returns:
- the current value
-
getAndAdd
reactor.core.publisher.Mono<> getAndAdd(double delta)
Atomically adds the given value to the current value.- Parameters:
delta
- the value to add- Returns:
- the updated value
-
getAndSet
reactor.core.publisher.Mono<> getAndSet(double newValue)
Atomically sets the given value and returns the old value.- Parameters:
newValue
- the new value- Returns:
- the old value
-
incrementAndGet
reactor.core.publisher.Mono<> incrementAndGet()
Atomically increments the current value by one.- Returns:
- the updated value
-
getAndIncrement
reactor.core.publisher.Mono<> getAndIncrement()
Atomically increments the current value by one.- Returns:
- the old value
-
getAndDecrement
reactor.core.publisher.Mono<> getAndDecrement()
Atomically decrements by one the current value.- Returns:
- the previous value
-
set
reactor.core.publisher.Mono<> set(double newValue)
Atomically sets the given value.- Parameters:
newValue
- the new value- Returns:
- void
-
-