From f41e905842ad05510f8f070258e9ec5187f66b68 Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Sat, 11 Jul 2020 11:02:18 +0800
Subject: [PATCH] =?UTF-8?q?RetResult=E5=A2=9E=E5=8A=A0CompletableFuture?=
 =?UTF-8?q?=E7=9B=B8=E5=85=B3=E6=96=B9=E6=B3=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/org/redkale/service/RetResult.java | 14 +++++++++++++-
 1 file changed, 13 insertions(+), 1 deletion(-)

diff --git a/src/org/redkale/service/RetResult.java b/src/org/redkale/service/RetResult.java
index 79f1171ea..bf0266009 100644
--- a/src/org/redkale/service/RetResult.java
+++ b/src/org/redkale/service/RetResult.java
@@ -7,7 +7,7 @@ package org.redkale.service;
 
 import java.lang.reflect.Type;
 import java.util.*;
-import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.*;
 import java.util.function.Function;
 import org.redkale.convert.*;
 import org.redkale.convert.json.*;
@@ -93,6 +93,10 @@ public class RetResult<T> {
         return this;
     }
 
+    public CompletableFuture<RetResult<T>> toFuture() {
+        return CompletableFuture.completedFuture(this);
+    }
+
     public static RetResult success() {
         return new RetResult();
     }
@@ -109,6 +113,14 @@ public class RetResult<T> {
         return CompletableFuture.completedFuture(new RetResult(result));
     }
 
+    public static <T> RetResult<T> get(CompletableFuture<RetResult<T>> future, long timeout, TimeUnit unit) {
+        try {
+            return future.get(timeout, unit);
+        } catch (Exception ex) {
+            throw new RuntimeException(ex);
+        }
+    }
+
     public static RetResult<Map<String, String>> map(String... items) {
         return new RetResult(Utility.ofMap(items));
     }