如何将scala.concurrent.Future转换为RxPromise

val promise = new RxPromise[T]()

val observable = Observable.fromFuture(future)

observable.subscribe(
  value => promise.success(value),
  error => promise.failure(error)
)

promise

import rx.lang.scala.Observable
import rx.lang.scala.RxPromise

def convertFutureToPromise[T](future: scala.concurrent.Future[T]): RxPromise[T] = {
  val promise = new RxPromise[T]()
  val observable = Observable.fromFuture(future)
  observable.subscribe(
    value => promise.success(value),
    error => promise.failure(error)
  )
  promise
}