compilation fixed

pull/605/head
Nikita 9 years ago
parent 7b4594f682
commit 49b23d4e28

@ -35,106 +35,127 @@ public class PromiseDelegator<T> implements RPromise<T> {
return promise; return promise;
} }
@Override
public RPromise<T> setSuccess(T result) { public RPromise<T> setSuccess(T result) {
return promise.setSuccess(result); return promise.setSuccess(result);
} }
@Override
public boolean isSuccess() { public boolean isSuccess() {
return promise.isSuccess(); return promise.isSuccess();
} }
@Override
public boolean trySuccess(T result) { public boolean trySuccess(T result) {
return promise.trySuccess(result); return promise.trySuccess(result);
} }
public boolean isCancellable() { @Override
return promise.isCancellable();
}
public Throwable cause() { public Throwable cause() {
return promise.cause(); return promise.cause();
} }
@Override
public Promise<T> setFailure(Throwable cause) { public Promise<T> setFailure(Throwable cause) {
return promise.setFailure(cause); return promise.setFailure(cause);
} }
@Override
public boolean tryFailure(Throwable cause) { public boolean tryFailure(Throwable cause) {
return promise.tryFailure(cause); return promise.tryFailure(cause);
} }
@Override
public boolean setUncancellable() { public boolean setUncancellable() {
return promise.setUncancellable(); return promise.setUncancellable();
} }
@Override
public RPromise<T> addListener(FutureListener<? super T> listener) { public RPromise<T> addListener(FutureListener<? super T> listener) {
return promise.addListener(listener); return promise.addListener(listener);
} }
@Override
public RPromise<T> addListeners(FutureListener<? super T>... listeners) { public RPromise<T> addListeners(FutureListener<? super T>... listeners) {
return promise.addListeners(listeners); return promise.addListeners(listeners);
} }
@Override
public RPromise<T> removeListener(FutureListener<? super T> listener) { public RPromise<T> removeListener(FutureListener<? super T> listener) {
return promise.removeListener(listener); return promise.removeListener(listener);
} }
@Override
public RPromise<T> removeListeners(FutureListener<? super T>... listeners) { public RPromise<T> removeListeners(FutureListener<? super T>... listeners) {
return promise.removeListeners(listeners); return promise.removeListeners(listeners);
} }
@Override
public RPromise<T> await() throws InterruptedException { public RPromise<T> await() throws InterruptedException {
return promise.await(); return promise.await();
} }
@Override
public RPromise<T> awaitUninterruptibly() { public RPromise<T> awaitUninterruptibly() {
return promise.awaitUninterruptibly(); return promise.awaitUninterruptibly();
} }
@Override
public RPromise<T> sync() throws InterruptedException { public RPromise<T> sync() throws InterruptedException {
return promise.sync(); return promise.sync();
} }
@Override
public RPromise<T> syncUninterruptibly() { public RPromise<T> syncUninterruptibly() {
return promise.syncUninterruptibly(); return promise.syncUninterruptibly();
} }
@Override
public boolean await(long timeout, TimeUnit unit) throws InterruptedException { public boolean await(long timeout, TimeUnit unit) throws InterruptedException {
return promise.await(timeout, unit); return promise.await(timeout, unit);
} }
@Override
public boolean isCancelled() { public boolean isCancelled() {
return promise.isCancelled(); return promise.isCancelled();
} }
@Override
public boolean isDone() { public boolean isDone() {
return promise.isDone(); return promise.isDone();
} }
@Override
public boolean await(long timeoutMillis) throws InterruptedException { public boolean await(long timeoutMillis) throws InterruptedException {
return promise.await(timeoutMillis); return promise.await(timeoutMillis);
} }
@Override
public T get() throws InterruptedException, ExecutionException { public T get() throws InterruptedException, ExecutionException {
return promise.get(); return promise.get();
} }
@Override
public boolean awaitUninterruptibly(long timeout, TimeUnit unit) { public boolean awaitUninterruptibly(long timeout, TimeUnit unit) {
return promise.awaitUninterruptibly(timeout, unit); return promise.awaitUninterruptibly(timeout, unit);
} }
@Override
public T get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException { public T get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException {
return promise.get(timeout, unit); return promise.get(timeout, unit);
} }
@Override
public boolean awaitUninterruptibly(long timeoutMillis) { public boolean awaitUninterruptibly(long timeoutMillis) {
return promise.awaitUninterruptibly(timeoutMillis); return promise.awaitUninterruptibly(timeoutMillis);
} }
@Override
public T getNow() { public T getNow() {
return promise.getNow(); return promise.getNow();
} }
@Override
public boolean cancel(boolean mayInterruptIfRunning) { public boolean cancel(boolean mayInterruptIfRunning) {
return promise.cancel(mayInterruptIfRunning); return promise.cancel(mayInterruptIfRunning);
} }

@ -56,11 +56,6 @@ public class RedissonPromise<T> implements RPromise<T> {
return promise.trySuccess(result); return promise.trySuccess(result);
} }
@Override
public boolean isCancellable() {
return promise.isCancellable();
}
@Override @Override
public Throwable cause() { public Throwable cause() {
return promise.cause(); return promise.cause();

Loading…
Cancel
Save