java - 将 Java CompletableFuture 转换为 TwitterFuture(没有任何中间 Future)

Question

我正在我的 scala 代码中使用 java 库，该库返回 CompletableFuture。

https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html

我必须将其转换为 TwitterFuture

https://twitter.github.io/util/guide/util-cookbook/futures.html

当然，我可以将 CompletableFuture 转换为 ScalaFuture，然后将 ScalaFuture 转换为 TwitterFuture。但这样就浪费了。

我可以将 CompletableFuture 直接转换为 TwitterFuture吗？

Answer 1

目前尚不清楚您具体要求什么。某个库中的一些标准方法？ Twitter Bijection是寻找它的明显位置，并且似乎没有 CompletionStage 或 CompletableFuture

的引用

如果你想要代码，那么@Dima是对的 - 自己编写它并不难，例如

import java.util.concurrent.CompletionStage
import java.util.function.BiConsumer
import com.twitter.util.{Future => TwitterFuture, Promise => TwitterPromise}

implicit class JavaCompletionStageTwitterOps[A](val jcs: CompletionStage[A]) extends AnyVal {
  def asTwitter(implicit e: ExecutionContext): TwitterFuture[A] = {
    val promise = new TwitterPromise[A] with BiConsumer[A, Throwable] {
      override def accept(value: A, ex: Throwable): Unit = {
        if (ex == null) this.setValue(value)
        else this.setException(ex)
      }
    }
    jcs.whenComplete(promise)
    promise
  }
}