Как конвертировать 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