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

Question

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

标签： rxjsscala.js

Answer 1

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

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