Блог

Учитывая scala.concurrent.Future[Int] есть ли функция, доступная для преобразования этого в RXPromise [Int]?

Я смог преобразовать, добавив следующую неявную функцию:

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