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

Question

给定scala.concurrent.Future [Int]是否有可用于将其转换为RxPromise [Int]的函数？

Answer 1

我能够通过添加以下隐式函数进行转换：

implicit def toRxPromise[T](fut: Future[T]): RxPromise[T] = Observable.fromPromise(fut.toJSPromise).toPromise