Package org.redisson.misc

Interface RPromise<T>

    • Method Detail

      • trySuccess

        boolean trySuccess​(T result)
        Marks this future as a success and notifies all listeners.
        Parameters:
        result - object
        Returns:
        true if and only if successfully marked this future as a success. Otherwise false because this future is already marked as either a success or a failure.

      • tryFailure

        boolean tryFailure​( cause)
        Marks this future as a failure and notifies all listeners.
        Parameters:
        cause - object
        Returns:
        true if and only if successfully marked this future as a failure. Otherwise false because this future is already marked as either a success or a failure.

      • setUncancellable

        boolean setUncancellable()
        Make this future impossible to cancel.
        Returns:
        true if and only if successfully marked this future as uncancellable or it is already done without being cancelled. false if this future has been cancelled already.

      • await

        RPromise<T> await()
           throws
        Description copied from interface: RFuture
        Waits for this future to be completed.
        Specified by:
        await in interface RFuture<T>
        Returns:
        Future object
        Throws:
        - if the current thread was interrupted

      • awaitUninterruptibly

        RPromise<T> awaitUninterruptibly()
        Description copied from interface: RFuture
        Waits for this future to be completed without interruption. This method catches an and discards it silently.
        Specified by:
        awaitUninterruptibly in interface RFuture<T>
        Returns:
        Future object

      • sync

        RPromise<T> sync()
          throws
        Description copied from interface: RFuture
        Waits for this future until it is done, and rethrows the cause of the failure if this future failed.
        Specified by:
        sync in interface RFuture<T>
        Returns:
        Future object
        Throws:
        - if the current thread was interrupted

      • syncUninterruptibly

        RPromise<T> syncUninterruptibly()
        Description copied from interface: RFuture
        Waits for this future until it is done, and rethrows the cause of the failure if this future failed.
        Specified by:
        syncUninterruptibly in interface RFuture<T>
        Returns:
        Future object

      • hasListeners

        boolean hasListeners()