Package org.redisson.api

Interface RAtomicDoubleRx

  • All Superinterfaces:
    RExpirableRx, RObjectRx
    public interface RAtomicDoubleRx
extends RExpirableRx
    Reactive interface for AtomicDouble object
    Author:
    Nikita Koksharov

    • Method Detail

      • compareAndSet

        io.reactivex.rxjava3.core.Single<Boolean> 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 value
        update - the new value
        Returns:
        true if successful; or false if the actual value was not equal to the expected value.

      • addAndGet

        io.reactivex.rxjava3.core.Single<Double> addAndGet(double delta)
        Atomically adds the given value to the current value.
        Parameters:
        delta - the value to add
        Returns:
        the updated value

      • decrementAndGet

        io.reactivex.rxjava3.core.Single<Double> decrementAndGet()
        Atomically decrements the current value by one.
        Returns:
        the updated value

      • get

        io.reactivex.rxjava3.core.Single<Double> get()
        Returns current value.
        Returns:
        current value

      • getAndDelete

        io.reactivex.rxjava3.core.Single<Double> getAndDelete()
        Returns and deletes object
        Returns:
        the current value

      • getAndAdd

        io.reactivex.rxjava3.core.Single<Double> getAndAdd(double delta)
        Atomically adds the given value to the current value.
        Parameters:
        delta - the value to add
        Returns:
        the updated value

      • getAndSet

        io.reactivex.rxjava3.core.Single<Double> getAndSet(double newValue)
        Atomically sets the given value and returns the old value.
        Parameters:
        newValue - the new value
        Returns:
        the old value

      • incrementAndGet

        io.reactivex.rxjava3.core.Single<Double> incrementAndGet()
        Atomically increments the current value by one.
        Returns:
        the updated value

      • getAndIncrement

        io.reactivex.rxjava3.core.Single<Double> getAndIncrement()
        Atomically increments the current value by one.
        Returns:
        the old value

      • getAndDecrement

        io.reactivex.rxjava3.core.Single<Double> getAndDecrement()
        Atomically decrements by one the current value.
        Returns:
        the previous value

      • set

        io.reactivex.rxjava3.core.Completable set(double newValue)
        Atomically sets the given value.
        Parameters:
        newValue - the new value
        Returns:
        void