This is an automated email from the ASF dual-hosted git repository.
liujun pushed a commit to branch 3.x-dev
in repository https://gitbox.apache.org/repos/asf/incubator-dubbo.git
The following commit(s) were added to refs/heads/3.x-dev by this push:
new 948d31c rename property to avoid possible confusion
948d31c is described below
commit 948d31c57fcc43b9974b7730f5031b09541a51ca
Author: ken.lj <[email protected]>
AuthorDate: Wed Apr 24 14:52:29 2019 +0800
rename property to avoid possible confusion
---
.../java/org/apache/dubbo/rpc/protocol/dubbo/FutureAdapter.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git
a/dubbo-rpc/dubbo-rpc-dubbo/src/main/java/org/apache/dubbo/rpc/protocol/dubbo/FutureAdapter.java
b/dubbo-rpc/dubbo-rpc-dubbo/src/main/java/org/apache/dubbo/rpc/protocol/dubbo/FutureAdapter.java
index d00c5fa..03954d1 100644
---
a/dubbo-rpc/dubbo-rpc-dubbo/src/main/java/org/apache/dubbo/rpc/protocol/dubbo/FutureAdapter.java
+++
b/dubbo-rpc/dubbo-rpc-dubbo/src/main/java/org/apache/dubbo/rpc/protocol/dubbo/FutureAdapter.java
@@ -30,10 +30,10 @@ import java.util.concurrent.TimeoutException;
*/
public class FutureAdapter<V> extends CompletableFuture<V> {
- private CompletableFuture<AppResponse> resultFuture;
+ private CompletableFuture<AppResponse> appResponseFuture;
public FutureAdapter(CompletableFuture<AppResponse> future) {
- this.resultFuture = future;
+ this.appResponseFuture = future;
future.whenComplete((appResponse, t) -> {
if (t != null) {
if (t instanceof CompletionException) {
@@ -53,12 +53,12 @@ public class FutureAdapter<V> extends CompletableFuture<V> {
// TODO figure out the meaning of cancel in DefaultFuture.
@Override
public boolean cancel(boolean mayInterruptIfRunning) {
- return resultFuture.cancel(mayInterruptIfRunning);
+ return appResponseFuture.cancel(mayInterruptIfRunning);
}
@Override
public boolean isCancelled() {
- return resultFuture.isCancelled();
+ return appResponseFuture.isCancelled();
}
@Override