Class ScalaFutureUtils
- java.lang.Object
-
- org.apache.flink.runtime.concurrent.pekko.ScalaFutureUtils
-
public class ScalaFutureUtils extends Object
Utilities to convert Scala types into Java types.
-
-
Constructor Summary
Constructors Constructor Description ScalaFutureUtils()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <T,U extends T>
CompletableFuture<T>toJava(scala.concurrent.Future<U> scalaFuture)
Converts a ScalaFuture
to aCompletableFuture
.
-
-
-
Method Detail
-
toJava
public static <T,U extends T> CompletableFuture<T> toJava(scala.concurrent.Future<U> scalaFuture)
Converts a ScalaFuture
to aCompletableFuture
.- Type Parameters:
T
- type of the future valueU
- type of the original future- Parameters:
scalaFuture
- to convert to a Java 8 CompletableFuture- Returns:
- Java 8 CompletableFuture
-
-