Наблюдаемый withLatestFrom не срабатывает при использовании с Observable.just(1)

withLatestFrom не стреляет при использовании с Observable.just(1) как показано ниже. Как будто это зашло в тупик.

rxPositionCapability.position является Observable<Position> это очень часто обновляется в вычислительном потоке. это setPositionPercent звонок идет из основного потока.

Что может помешать withLatestFrom от бега?

Я даже использую Observable.just(1) правильно? Я пытаюсь получить доступ к текущему значению из Observable, необходимого для вычисления API-вызова.

override fun setPositionPercent( value:Double ) {
    Observable.just(1)
              .withLatestFrom(rxPositionCapability.position) { _, position:Position ->
                    // never runs
                    rxPositionCapability.setPosition( position.duration * value )
              }
              .subscribe()
}

0 ответов

Другие вопросы по тегам