org.opendaylight.controller.sal.core.compat

Class AbstractDOMRpcResultFutureAdapter<T extends org.opendaylight.mdsal.dom.api.DOMRpcResult,F extends org.opendaylight.mdsal.dom.api.DOMRpcResult,D extends com.google.common.util.concurrent.ListenableFuture<F>,E extends org.opendaylight.mdsal.dom.api.DOMRpcException>

java.lang.Object

com.google.common.util.concurrent.internal.InternalFutureFailureAccess

com.google.common.util.concurrent.AbstractFuture<T>

org.opendaylight.controller.sal.core.compat.AbstractDOMRpcResultFutureAdapter<T,F,D,E>

All Implemented Interfaces:

com.google.common.util.concurrent.ListenableFuture<T>, Future<T>

Direct Known Subclasses:

LegacyDOMRpcResultFutureAdapter, MdsalDOMRpcResultFutureAdapter

public abstract class AbstractDOMRpcResultFutureAdapter<T extends org.opendaylight.mdsal.dom.api.DOMRpcResult,F extends org.opendaylight.mdsal.dom.api.DOMRpcResult,D extends com.google.common.util.concurrent.ListenableFuture<F>,E extends org.opendaylight.mdsal.dom.api.DOMRpcException>
extends com.google.common.util.concurrent.AbstractFuture<T>

Base for a DOMRpcResult future adapter.

Author:

Thomas Pantelis

Method Summary

Modifier and Type	Method and Description
void	addListener(Runnable listener, Executor executor)
boolean	cancel(boolean mayInterruptIfRunning)
D	delegate()
T	get()
T	get(long timeout, TimeUnit unit)
boolean	isCancelled()
boolean	isDone()
protected abstract T	transform(F fromResult)

Methods inherited from class com.google.common.util.concurrent.AbstractFuture

afterDone, interruptTask, pendingToString, set, setException, setFuture, toString, tryInternalFastPathGetFailure, wasInterrupted

Methods inherited from class java.lang.Object

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

Method Detail

transform

protected abstract T transform(F fromResult)

delegate

public D delegate()

addListener

public void addListener(Runnable listener,
                        Executor executor)

Specified by:

addListener in interface com.google.common.util.concurrent.ListenableFuture<T extends org.opendaylight.mdsal.dom.api.DOMRpcResult>

Overrides:

addListener in class com.google.common.util.concurrent.AbstractFuture<T extends org.opendaylight.mdsal.dom.api.DOMRpcResult>

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<T extends org.opendaylight.mdsal.dom.api.DOMRpcResult>

Overrides:

cancel in class com.google.common.util.concurrent.AbstractFuture<T extends org.opendaylight.mdsal.dom.api.DOMRpcResult>

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Future<T extends org.opendaylight.mdsal.dom.api.DOMRpcResult>

Overrides:

isCancelled in class com.google.common.util.concurrent.AbstractFuture<T extends org.opendaylight.mdsal.dom.api.DOMRpcResult>

isDone

public boolean isDone()

Specified by:

isDone in interface Future<T extends org.opendaylight.mdsal.dom.api.DOMRpcResult>

Overrides:

isDone in class com.google.common.util.concurrent.AbstractFuture<T extends org.opendaylight.mdsal.dom.api.DOMRpcResult>

get

public T get()
      throws InterruptedException,
             ExecutionException

Specified by:

get in interface Future<T extends org.opendaylight.mdsal.dom.api.DOMRpcResult>

Overrides:

get in class com.google.common.util.concurrent.AbstractFuture<T extends org.opendaylight.mdsal.dom.api.DOMRpcResult>

Throws:

InterruptedException

ExecutionException

get

public T get(long timeout,
             TimeUnit unit)
      throws InterruptedException,
             ExecutionException,
             TimeoutException

Specified by:

get in interface Future<T extends org.opendaylight.mdsal.dom.api.DOMRpcResult>

Overrides:

get in class com.google.common.util.concurrent.AbstractFuture<T extends org.opendaylight.mdsal.dom.api.DOMRpcResult>

Throws:

InterruptedException

ExecutionException

TimeoutException