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()
}