Наблюдаемый 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()
}