Future.cancel method handling for remote method call. #560
Nikita
9 years ago
parent
a3e8af5995
commit
5a0b32f6ae
@ -0,0 +1,140 @@
|
||||
/**
|
||||
* Copyright 2016 Nikita Koksharov
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.redisson.misc;
|
||||
|
||||
import java.util.concurrent.ExecutionException;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
import java.util.concurrent.TimeoutException;
|
||||
|
||||
import io.netty.util.concurrent.Future;
|
||||
import io.netty.util.concurrent.GenericFutureListener;
|
||||
import io.netty.util.concurrent.Promise;
|
||||
|
||||
public class PromiseDelegator<T> implements Promise<T> {
|
||||
|
||||
private final Promise<T> promise;
|
||||
|
||||
public PromiseDelegator(Promise<T> promise) {
|
||||
super();
|
||||
this.promise = promise;
|
||||
}
|
||||
|
||||
public Promise<T> setSuccess(T result) {
|
||||
return promise.setSuccess(result);
|
||||
}
|
||||
|
||||
public boolean isSuccess() {
|
||||
return promise.isSuccess();
|
||||
}
|
||||
|
||||
public boolean trySuccess(T result) {
|
||||
return promise.trySuccess(result);
|
||||
}
|
||||
|
||||
public boolean isCancellable() {
|
||||
return promise.isCancellable();
|
||||
}
|
||||
|
||||
public Throwable cause() {
|
||||
return promise.cause();
|
||||
}
|
||||
|
||||
public Promise<T> setFailure(Throwable cause) {
|
||||
return promise.setFailure(cause);
|
||||
}
|
||||
|
||||
public boolean tryFailure(Throwable cause) {
|
||||
return promise.tryFailure(cause);
|
||||
}
|
||||
|
||||
public boolean setUncancellable() {
|
||||
return promise.setUncancellable();
|
||||
}
|
||||
|
||||
public Promise<T> addListener(GenericFutureListener<? extends Future<? super T>> listener) {
|
||||
return promise.addListener(listener);
|
||||
}
|
||||
|
||||
public Promise<T> addListeners(GenericFutureListener<? extends Future<? super T>>... listeners) {
|
||||
return promise.addListeners(listeners);
|
||||
}
|
||||
|
||||
public Promise<T> removeListener(GenericFutureListener<? extends Future<? super T>> listener) {
|
||||
return promise.removeListener(listener);
|
||||
}
|
||||
|
||||
public Promise<T> removeListeners(GenericFutureListener<? extends Future<? super T>>... listeners) {
|
||||
return promise.removeListeners(listeners);
|
||||
}
|
||||
|
||||
public Promise<T> await() throws InterruptedException {
|
||||
return promise.await();
|
||||
}
|
||||
|
||||
public Promise<T> awaitUninterruptibly() {
|
||||
return promise.awaitUninterruptibly();
|
||||
}
|
||||
|
||||
public Promise<T> sync() throws InterruptedException {
|
||||
return promise.sync();
|
||||
}
|
||||
|
||||
public Promise<T> syncUninterruptibly() {
|
||||
return promise.syncUninterruptibly();
|
||||
}
|
||||
|
||||
public boolean await(long timeout, TimeUnit unit) throws InterruptedException {
|
||||
return promise.await(timeout, unit);
|
||||
}
|
||||
|
||||
public boolean isCancelled() {
|
||||
return promise.isCancelled();
|
||||
}
|
||||
|
||||
public boolean isDone() {
|
||||
return promise.isDone();
|
||||
}
|
||||
|
||||
public boolean await(long timeoutMillis) throws InterruptedException {
|
||||
return promise.await(timeoutMillis);
|
||||
}
|
||||
|
||||
public T get() throws InterruptedException, ExecutionException {
|
||||
return promise.get();
|
||||
}
|
||||
|
||||
public boolean awaitUninterruptibly(long timeout, TimeUnit unit) {
|
||||
return promise.awaitUninterruptibly(timeout, unit);
|
||||
}
|
||||
|
||||
public T get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException {
|
||||
return promise.get(timeout, unit);
|
||||
}
|
||||
|
||||
public boolean awaitUninterruptibly(long timeoutMillis) {
|
||||
return promise.awaitUninterruptibly(timeoutMillis);
|
||||
}
|
||||
|
||||
public T getNow() {
|
||||
return promise.getNow();
|
||||
}
|
||||
|
||||
public boolean cancel(boolean mayInterruptIfRunning) {
|
||||
return promise.cancel(mayInterruptIfRunning);
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
Loading…
Reference in New Issue