将CompletableFuture (Java 8)转换为Future (Scala)

Question

我想将下面方法的返回类型更改为< code>Future[Unit]

def send(data: Array[Byte]): CompletableFuture[Void] = {
  val f:CompletableFuture[Void] = client.send(data)
  f
}

我使用的是Scala 2.12.1。是否有任何方便的方法可以将Java 8＜code＞CompletableFuture

Answer 1

要将CompletableFuture转换为Scala的未来并摆脱包装的CompletefulException：：

package mycompany.common.concurrent

object Extensions {
  implicit class UnwrappedCompletableFuture[T](cf: CompletableFuture[T]) {

    import scala.jdk.FutureConverters._

    def toScala: Future[T] = {
      val f = cf.asScala
      f.recover {
        case ex: CompletionException if ex.getCause != null => throw ex.getCause
      }(ExecutionContext.global)
    }
  }
}

用法:

import mycompany.common.concurrent.Extensions._

val result = fetcher.fetchAsync().toScala.recover {
  case ex: YourActualException => 
}

Answer 2

虽然asker（在2017年）提到了2.12，但现在我们有了2.13，转换变得更加容易：

从 Scala 2.13 开始，标准库包含 scala.jdk.FutureConverters，它提供了 Java 到 Scala CompletableFuture/Future 隐式转换：

import scala.jdk.FutureConverters._

val scalaFuture = javaFuture.asScala

将Java未来转换为Scala未来

Answer 3

是的，它叫做scala-java8-compat，这就是你要找的方法。