fix apache#6555, backward compatibility: com.alibaba.dubbo.rpc.protoc…

…ol.dubbo.FutureAdapter missing constructor. (apache#6675)
iMine141 · Sep 1, 2020 · e952d8e · e952d8e
1 parent 611be16
commit e952d8e
Showing 1 changed file with 15 additions and 0 deletions.
diff --git a/dubbo-compatible/src/main/java/com/alibaba/dubbo/rpc/protocol/dubbo/FutureAdapter.java b/dubbo-compatible/src/main/java/com/alibaba/dubbo/rpc/protocol/dubbo/FutureAdapter.java
@@ -45,6 +45,21 @@ public FutureAdapter(CompletableFuture<Object> future) {
         this.future = future;
     }
 
+    public FutureAdapter(ResponseFuture responseFuture) {
+        this.future = new CompletableFuture<>();
+        responseFuture.setCallback(new ResponseCallback() {
+            @Override
+            public void done(Object response) {
+                future.complete(response);
+            }
+
+            @Override
+            public void caught(Throwable exception) {
+                future.completeExceptionally(exception);
+            }
+        });
+    }
+
     public ResponseFuture getFuture() {
         return new ResponseFuture() {
             @Override