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 { return this; } + public CompletableFuture> toFuture() { + return CompletableFuture.completedFuture(this); + } + public static RetResult success() { return new RetResult(); } @@ -109,6 +113,14 @@ public class RetResult { return CompletableFuture.completedFuture(new RetResult(result)); } + public static RetResult get(CompletableFuture> future, long timeout, TimeUnit unit) { + try { + return future.get(timeout, unit); + } catch (Exception ex) { + throw new RuntimeException(ex); + } + } + public static RetResult> map(String... items) { return new RetResult(Utility.ofMap(items)); }