You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by li...@apache.org on 2020/02/09 04:56:20 UTC
[dubbo] branch master updated: fix:Remove unused variable
parameters in AbstractProxyInvoker (#5651)
This is an automated email from the ASF dual-hosted git repository.
liujun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/dubbo.git
The following commit(s) were added to refs/heads/master by this push:
new 5b4816d fix:Remove unused variable parameters in AbstractProxyInvoker (#5651)
5b4816d is described below
commit 5b4816dfa6ae92d0b94af4ed41c07ca6c9d0fcb9
Author: LiosWong <di...@163.com>
AuthorDate: Sun Feb 9 12:56:11 2020 +0800
fix:Remove unused variable parameters in AbstractProxyInvoker (#5651)
---
.../main/java/org/apache/dubbo/rpc/proxy/AbstractProxyInvoker.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/proxy/AbstractProxyInvoker.java b/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/proxy/AbstractProxyInvoker.java
index 6abac55..6d74825 100644
--- a/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/proxy/AbstractProxyInvoker.java
+++ b/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/proxy/AbstractProxyInvoker.java
@@ -82,7 +82,7 @@ public abstract class AbstractProxyInvoker<T> implements Invoker<T> {
public Result invoke(Invocation invocation) throws RpcException {
try {
Object value = doInvoke(proxy, invocation.getMethodName(), invocation.getParameterTypes(), invocation.getArguments());
- CompletableFuture<Object> future = wrapWithFuture(value, invocation);
+ CompletableFuture<Object> future = wrapWithFuture(value);
CompletableFuture<AppResponse> appResponseFuture = future.handle((obj, t) -> {
AppResponse result = new AppResponse();
if (t != null) {
@@ -107,7 +107,7 @@ public abstract class AbstractProxyInvoker<T> implements Invoker<T> {
}
}
- private CompletableFuture<Object> wrapWithFuture (Object value, Invocation invocation) {
+ private CompletableFuture<Object> wrapWithFuture(Object value) {
if (RpcContext.getContext().isAsyncStarted()) {
return ((AsyncContextImpl)(RpcContext.getContext().getAsyncContext())).getInternalFuture();
} else if (value instanceof CompletableFuture) {