Package org.apache.cassandra.net

Class FutureDelegate<V>

java.lang.Object
org.apache.cassandra.net.FutureDelegate<V>
All Implemented Interfaces:
io.netty.util.concurrent.Future<V>, Future<V>
Direct Known Subclasses:
FutureResult
public class FutureDelegate<V> extends 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 Details

    • 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 Throwable cause()
      Specified by:
      cause in interface io.netty.util.concurrent.Future<V>

    • sync

      public io.netty.util.concurrent.Future<V> sync() throws InterruptedException
      Specified by:
      sync in interface io.netty.util.concurrent.Future<V>
      Throws:
      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 InterruptedException
      Specified by:
      await in interface io.netty.util.concurrent.Future<V>
      Throws:
      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, TimeUnit timeUnit) throws InterruptedException
      Specified by:
      await in interface io.netty.util.concurrent.Future<V>
      Throws:
      InterruptedException

    • await

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

    • awaitUninterruptibly

      public boolean awaitUninterruptibly(long l, 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 Future<V>

    • isCancelled

      public boolean isCancelled()
      Specified by:
      isCancelled in interface Future<V>

    • isDone

      public boolean isDone()
      Specified by:
      isDone in interface Future<V>

    • get

      public V get() throws InterruptedException, ExecutionException
      Specified by:
      get in interface Future<V>
      Throws:
      InterruptedException
      ExecutionException

    • get

      public V get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException
      Specified by:
      get in interface Future<V>
      Throws:
      InterruptedException
      ExecutionException
      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>