RxJava2 таймер и combLatest

новый для RxJava2 У меня проблемы с timer и combineLatest например:

 Observable.combineLatest( Observable.timer(5, TimeUnit.SECONDS).map { TimedData(it) }, locationDataSource.listen(), sensorDataSource.listen(). Function3 { timedData, location, sensorEvent -> Combined(timedData, location, sensorEvent) } ).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe { Log.d(TAG, "Timer -> " + it.timedData) } 

Что происходит, так это то, что timedData только один раз, затем он никогда не срабатывает снова, все остальные наблюдаемые начинают обновляться. Я нашел https://github.com/ReactiveX/RxJava/issues/1717, но это с 2014 года, поэтому я думаю, что он уже разрешен.

Это все еще происходит из-за BackPressure?

Это работает так, как было разработано. Observable.timer планирует выполнение одной задачи для однократного запуска. Если вы хотите, чтобы что-то выполнялось, периодически проверяйте interval а не timer .

 Observable.interval(0,5, TimeUnit.SECONDS); 
Intereting Posts
Как установить прокси для Spring AsyncRestTemplate с помощью Netty4ClientHttpRequestFactory? Ошибка Required Nothing при определении нулевой локальной переменной и ее установка позже в методе Ошибки расширения Kotlin Переменные деструктурирования Kotlin не работают с Pair, Triple или классом данных Как объявить класс, содержащий поле с общим типом в Котлин? Kotlin Удалить все не буквенно-цифровые символы Сохранять ViewModels с объемом фрагмента во вращающемся экране kotlin и @Valid Spring аннотация Почему использование аннотаций Scopes и Singleton в Dagger2 с kotlin вызывает ошибку при компиляции? Hibernate игнорирует «ленивый» тип выборки и сразу загружает свойства Почему этот способ случайного создания графика несправедлив? Использование @JvmOverloads Kotlin с шаблоном Fragment.newInstance () Android Преобразование API библиотеки Android в Kotlin Kotlin – Как создать функцию псевдонима RxJava flatmap ()? Запуск HTML-редактора Kotlin в браузере