Package org.apache.cassandra.net

Class FutureDelegate<V>

  • All Implemented Interfaces:
    io.netty.util.concurrent.Future<V>, java.util.concurrent.Future<V>
    Direct Known Subclasses:
    FutureResult
    public class FutureDelegate<V>
extends java.lang.Object
implements io.netty.util.concurrent.Future<V>
    A delegating future, that we can extend to provide subtly modified behaviour. See FutureCombiner and FutureResult

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      io.netty.util.concurrent.Future<V> addListener​(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>> genericFutureListener)  
      io.netty.util.concurrent.Future<V> addListeners​(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>>... genericFutureListeners)  
      io.netty.util.concurrent.Future<V> await()  
      boolean await​(long l)  
      boolean await​(long l, java.util.concurrent.TimeUnit timeUnit)  
      io.netty.util.concurrent.Future<V> awaitUninterruptibly()  
      boolean awaitUninterruptibly​(long l)  
      boolean awaitUninterruptibly​(long l, java.util.concurrent.TimeUnit timeUnit)  
      boolean cancel​(boolean b)  
      java.lang.Throwable cause()  
      V get()  
      V get​(long timeout, java.util.concurrent.TimeUnit unit)  
      V getNow()  
      boolean isCancellable()  
      boolean isCancelled()  
      boolean isDone()  
      boolean isSuccess()  
      io.netty.util.concurrent.Future<V> removeListener​(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>> genericFutureListener)  
      io.netty.util.concurrent.Future<V> removeListeners​(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>>... genericFutureListeners)  
      io.netty.util.concurrent.Future<V> sync()  
      io.netty.util.concurrent.Future<V> syncUninterruptibly()  

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Method Detail

      • isSuccess

        public boolean isSuccess()
        Specified by:
        isSuccess in interface io.netty.util.concurrent.Future<V>

      • isCancellable

        public boolean isCancellable()
        Specified by:
        isCancellable in interface io.netty.util.concurrent.Future<V>

      • cause

        public java.lang.Throwable cause()
        Specified by:
        cause in interface io.netty.util.concurrent.Future<V>

      • sync

        public io.netty.util.concurrent.Future<V> sync()
                                        throws java.lang.InterruptedException
        Specified by:
        sync in interface io.netty.util.concurrent.Future<V>
        Throws:
        java.lang.InterruptedException

      • syncUninterruptibly

        public io.netty.util.concurrent.Future<V> syncUninterruptibly()
        Specified by:
        syncUninterruptibly in interface io.netty.util.concurrent.Future<V>

      • await

        public io.netty.util.concurrent.Future<V> await()
                                         throws java.lang.InterruptedException
        Specified by:
        await in interface io.netty.util.concurrent.Future<V>
        Throws:
        java.lang.InterruptedException

      • awaitUninterruptibly

        public io.netty.util.concurrent.Future<V> awaitUninterruptibly()
        Specified by:
        awaitUninterruptibly in interface io.netty.util.concurrent.Future<V>

      • await

        public boolean await​(long l,
                     java.util.concurrent.TimeUnit timeUnit)
              throws java.lang.InterruptedException
        Specified by:
        await in interface io.netty.util.concurrent.Future<V>
        Throws:
        java.lang.InterruptedException

      • await

        public boolean await​(long l)
              throws java.lang.InterruptedException
        Specified by:
        await in interface io.netty.util.concurrent.Future<V>
        Throws:
        java.lang.InterruptedException

      • awaitUninterruptibly

        public boolean awaitUninterruptibly​(long l,
                                    java.util.concurrent.TimeUnit timeUnit)
        Specified by:
        awaitUninterruptibly in interface io.netty.util.concurrent.Future<V>

      • awaitUninterruptibly

        public boolean awaitUninterruptibly​(long l)
        Specified by:
        awaitUninterruptibly in interface io.netty.util.concurrent.Future<V>

      • getNow

        public V getNow()
        Specified by:
        getNow in interface io.netty.util.concurrent.Future<V>

      • cancel

        public boolean cancel​(boolean b)
        Specified by:
        cancel in interface io.netty.util.concurrent.Future<V>
        Specified by:
        cancel in interface java.util.concurrent.Future<V>

      • isCancelled

        public boolean isCancelled()
        Specified by:
        isCancelled in interface java.util.concurrent.Future<V>

      • isDone

        public boolean isDone()
        Specified by:
        isDone in interface java.util.concurrent.Future<V>

      • get

        public V get()
      throws java.lang.InterruptedException,
             java.util.concurrent.ExecutionException
        Specified by:
        get in interface java.util.concurrent.Future<V>
        Throws:
        java.lang.InterruptedException
        java.util.concurrent.ExecutionException

      • get

        public V get​(long timeout,
             java.util.concurrent.TimeUnit unit)
      throws java.lang.InterruptedException,
             java.util.concurrent.ExecutionException,
             java.util.concurrent.TimeoutException
        Specified by:
        get in interface java.util.concurrent.Future<V>
        Throws:
        java.lang.InterruptedException
        java.util.concurrent.ExecutionException
        java.util.concurrent.TimeoutException

      • addListener

        public io.netty.util.concurrent.Future<V> addListener​(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>> genericFutureListener)
        Specified by:
        addListener in interface io.netty.util.concurrent.Future<V>

      • addListeners

        public io.netty.util.concurrent.Future<V> addListeners​(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>>... genericFutureListeners)
        Specified by:
        addListeners in interface io.netty.util.concurrent.Future<V>

      • removeListener

        public io.netty.util.concurrent.Future<V> removeListener​(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>> genericFutureListener)
        Specified by:
        removeListener in interface io.netty.util.concurrent.Future<V>

      • removeListeners

        public io.netty.util.concurrent.Future<V> removeListeners​(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>>... genericFutureListeners)
        Specified by:
        removeListeners in interface io.netty.util.concurrent.Future<V>