Вопросы с меткой [rxjava]
Java реализация ReactiveX, являющегося API для асинхронного программирования посредством наблюдения за потоками событий
242
вопроса
0
голосов
0
ответов
35
показов
Как работают Reactive Streams java?
В целом разобрался с механизмом работы Reactive Streams, но не понимаю момент, когда подписчик вызывает метод request(n) подписки(Subscription), чтобы запросить данные у издателя, как тот понимает, ...
2
голоса
1
ответ
48
показов
Почему subscribeOn() не отправляет предыдущее значение из Behaviour subject?
Изучаю нюансы работы методов subscribeOn() / observeOn() для Subjects. Не могу понять, почему в приведенном коде subscribeOn() запрещает отправку события str 0?
val observer: Observer<String&...
1
голос
0
ответов
34
показа
Статус подключения к серверу с помощью rxjava в Android
Имею подключение по websocket
object StompWrapper {
private var emitter: ObservableEmitter<Event>? = null
init {
val client = OkHttpClient.Builder().build()
val stomp = ...
1
голос
1
ответ
57
показов
Бесконечный цикл при обновлении в room с использованием rxJava
Все я заккоментил, чтобы найти источник зла.
model.updateFavorite(it) он входит в бесконечный цикл.
Его код
fun updateFavorite(pokemon: PokemonEntity){
Log.d("RefreshFavorite", ...
0
голосов
1
ответ
64
показа
Как сделать вызов асинхронным rxJava
У меня сейчас стоит задача получить список данных из интернета, через retrofit. И если код ответа не успешный(200), то взять этот список данных из бд(room).
Как мне сделать это правильно с rxJava?
Я ...
1
голос
1
ответ
101
показ
Когда отписываться от Observable?
Доброго времени суток !
пытаюсь разобраться со связкой RxJava + Retrofit
в интерфейсе retrofit есть метод возвращающий Single
@GET
fun getPicture(@Url url: String): Single<ResponseBody>
...
0
голосов
1
ответ
36
показов
Какую аннотацию поставить в функции интерфейса Dao для Rxjava
У меня есть две функции находящиеся в Dao для работы с Rxjava надо пометить аннотацией Single,Completable и т.д. ,но мне выдает ошибку
error: Not sure how to convert a Cursor to this method's return ...
0
голосов
1
ответ
909
показов
Java Observer и Observable
Только начинаю погружение в Java. Не могу понять один момент, можем ли мы использовать один наблюдатель - Observer для разных объектов наблюдения - Observable или должно быть строго, один Observer ...
0
голосов
0
ответов
44
показа
Как подписаться на два observable разного типа за раз? rxjava
У меня есть два observable разного типа.
val urlContent = contentRepo.getUrlContent(urls).toObservable()
val isConnected = Observable.interval(1, TimeUnit.SECONDS).flatMap {
...
0
голосов
2
ответа
97
показов
Получение Observable<List<B>> из Observable<List<A>>
Есть два метода:
fun getMovieActors(id: Long) =
provider.retrofit
.loadMovieCreditsById(id, WebProvider.API_KEY)
.subscribeOn(Schedulers.io())
.map { credits ->
...
0
голосов
1
ответ
56
показов
RxJava сортировка списка по одну из эллементов
Имею json из такими строками как title, time, click_url, img, type, top и тд.
Я получаю список эллеметов со строками которые я описал выше.
Мне нужно Получить список эллеметов который будет иметь ...
1
голос
0
ответов
31
показ
RxJava - как реактивно подставлять наблюдаемые значения (в т.ч. пары) в запрос в Room, который так же возвращает Observable?
Во вьюМодели:
val searchQuery = Observable<String>
val catNumberOnlyTurnedoff = Observable<Pair<Int, Boolean>>
fun getWords(query: String, category: Int, onlyOff: Boolean) : ...
0
голосов
1
ответ
106
показов
Не могу получить данные из LiveData в UI
я новичок в Андроид.
Во ViewModel использую liveData(temperature) в которую передаю данные из сервера при помощи RxJava.
class WeatherTodayViewModel(application: Application) : AndroidViewModel(...
0
голосов
1
ответ
135
показов
Как правильно реализовать цепочку rxjava в android kotlin?
Я пытаюсь реализовать условия отсутствия интернета на мобильном устройстве. При этом должна происходить такая последовательность операций в цепочке:
1.Проверяем время последнего запроса
2.Делаем ...
1
голос
1
ответ
77
показов
Несколько Api запросов с использованием RxJava и Retrofit
Такой вот вопрос. Мне нужно сделать несколько Api запросов с использованием Retrotit и RxJava.
В первом запросе я получаю список из 20 фильмов. Мне нужно выводить список фильмов и инфу под каждым ...
0
голосов
1
ответ
57
показов
Синхронный RxJava запрос
У меня есть OkHttp Interceptor, который добавляет headers к запросам.
Проблема в том, что он делает это асинхронно(использую RxJava2) и запрос уходить до модификации Interceptor.
Код Interceptor:
...
0
голосов
1
ответ
54
показа
Обьеденить в один метод запрос с серва и запись в базу данных
У меня есть запрос из серва и из базы данных, суть в том, что бы при кадом запуске шла загрузка с базы данных, и с сервера который обновляет эту базу с помощью RxJava 2
Код который я придумал, но ...
1
голос
1
ответ
39
показов
Завершение стримов RxJava при закрытии активности в Android
Разбираюсь с использованием RxJava в Android, возник вопрос следующего рода. Я сделал вот такую extension функцию:
fun <T: View> T.setReactiveOnClickListener(): Flowable<View> {
val ...
0
голосов
0
ответов
39
показов
RecyclerView, видя два одинаковых подряд объекта, автоматически смещает "камеру" на второй, оставляя впередиидущий сверху вне поля видимости
In the Fragment:
@AndroidEntryPoint
class DrillerFragment : Fragment(R.layout.cardstack_layout), CardStackListener {
private val viewModel: DrillerViewModel by viewModels()
private lateinit ...
0
голосов
2
ответа
56
показов
Как вызвать onError после filter()
Мой observable генерирует случайное число от 1 до 5. Я фильтрую числа, чтобы они не были равны 4. Какие есть способы вызвать метод onError внутри активити, если значение будет равно 4? Проверять ...
0
голосов
1
ответ
59
показов
Дублирование ответов от Retrofit 2
я столкнулся с такой проблемой. Я делаю 2 запроса к внешнему API через Retrofit 2 + RxJava 3, но вместо одной строчки ответа они выводят по две. (Если сделать 3 запроса то каждый из них выведет по три ...
0
голосов
0
ответов
40
показов
Мерцает textView при обновлении с помощью rxJava
Есть фрагмет с таким кодом
StringObservable.from(inputStream)
.subscribeOn(Schedulers.io())
.map(String::new)
.map(s-> {
Log.d(&...
1
голос
0
ответов
59
показов
Retrofit2 + RxJava. Зачем?
У меня два вопроса:
Зачем использовать RxJava при работе с Retrofit2? Единственная причина что я находил - удобство обработки.
Если опустить это преимущество, то так ли нужна RxJava сейчас в ...
0
голосов
0
ответов
52
показа
RxJava - как в ViewModel передать метод из Репозитория в LiveData и указать потоки
In Dao:
@Query("SELECT * FROM person_table WHERE status = :status_debil ORDER BY RANDOM() LIMIT 5")
Single<List<Person>> getFivePersonsFrom(String status_debil);
In Repo:...
1
голос
1
ответ
76
показов
RxJava - не пойму как обернуть метод из Dao в Single в Репозитории
In Dao:
@Query("SELECT * FROM person_table WHERE status = :status_debil ORDER BY RANDOM() LIMIT 5")
List<Person> getFivePersonsFrom(String status_debil);
In Repo:
public class ...
0
голосов
0
ответов
99
показов
Перенос логики синхронизации с Kotlin корутин на iOS Swift в связке RxSwift+RxAlamofire
Есть некий функционал синхронизации, который хорошо рализован на корутинах. Код-пример ниже:
class SyncExample {
companion object {
const val TAG = "SyncExample"
val progress: ...
1
голос
0
ответов
82
показа
RxJava2 + Retrofit2: Почему в интерфейсе Retrofit часто используют именно Observable/Flowable?
Читал разные статьи и смотрел много видео на ютубе по связке RxJava и Retrofit, и очень часто видел примерно одну и ту же конструкцию:
@GET("some/endpoint")
fun getSomeData(): Observable<...
1
голос
1
ответ
91
показ
Реализация мгновенного поиска c RxJava
Пытаюсь делать в своем приложении мгновенный поиск пользователей из удаленной БД с RxJava. Следуя по одной статьи получилось сделать так: Сначала мне приходится получить всех пользователей,а потом ...
0
голосов
1
ответ
349
показов
В каком потоке выполняется subscribe() в RxJava?
У меня есть метод getText(), который получает из сети текст. Его нужно вставить в TextView.
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
...
2
голоса
0
ответов
39
показов
Тестирование аргументов переданных в Observable RxJava
Есть некий метод:
repository.get(arg1, arg2, arg3)
Который возвращает Single<List<SomeObject>>
Мне нужно протестировать, что на этот Single происходит подписка. Как протестировать ...
1
голос
1
ответ
260
показов
Android MVVM как получить ответ от ViewModel во View
У меня есть активити, у нее есть viewmodel. Viewmodel во время инициализации скачивает с сервера с помощью retrofit данные в json. Эти данные преобразуются в список объектов во viewmodel. И теперь мне ...
0
голосов
1
ответ
94
показа
WorkManager vs Rxjava
В чем разница между WorkManager и Rxjava? При каких обстоятельствах что использовать (примеры задач, пожалуйста)?
1
голос
1
ответ
90
показов
RxJava map vs Kotlin map
Раньше когда был Java 6 и Rx, при использовании RX подхода, делал mapping так
Single.just(listOf("1", "2", "3", "4"))
.toObservable()
....
1
голос
1
ответ
80
показов
Как правильно сделать асинхронные запросы, зависящие друг от друга RxJava Android
я новичек в RxJava. Задача следующая: есть 3 запроса
Получение токена
Валидация токена
Получение id сессии
Каждый запрос зависит от ответа предыдущего, т.е. сначала я делаю запрос на получение ...
0
голосов
0
ответов
76
показов
При использовании RxJava обновления подписчику не приходят
Я только начал изучать RxJava и столкнулся с проблемой.
У меня есть метод который делает запрос в Firebase Storage и при удачном исходе возвращает Observable(Uri)
public Observable<Uri> get() {
...
0
голосов
0
ответов
28
показов
По какой причине GSON может отдавать null?
Имеется стандартная связка в виде API Service (Retrofit + RxJava2CallAdapterFactory, GsonConverterFactory). Почему-то подписка сыпалась с null pointer в onError. Стал разбираться. Оказывается, null ...
0
голосов
1
ответ
82
показа
Как получить данные из БД Room с помощью RxJava если с удаленного сервера пришла ошибка
Всем привет. Пишу приложение в котором запрашивается погода с удаленного сервера. Для Api запроса использую библиотеку Retrofit и RxJava. Сейчас мне нужно добавить в приложение БД Room, если при Api ...
1
голос
0
ответов
60
показов
Подписка на обновления на сервере RxJava
В приложении на сервер загружается картинка. Эту картинку надо скачать и отобразить, но проблема в том, что она ещё не успевает загрузиться в базу данных. Хочу исправить это с помощью RxJava. Читал,...
1
голос
1
ответ
312
показов
Android RxJava: как правильно подписать PublishSubject на множество Observable?
Буду благодарен за любые подсказки и варианты как это поправить.
Задача: выдавать результаты вычислений асинхронно, по готовности.
Пример составлен для теста из рабочего кода, его можно использовать в ...
0
голосов
1
ответ
92
показа
не сохраняются данные в переменную в методе subscribe() RxJava
Всем привет. Не могу понять почему в теле метода subscrube() я присваиваю значение переменной coordinates,и сразу же вывожу значение переменной coordinates в Log и мне отображает нужный мне результат ...
1
голос
1
ответ
54
показа
Как вы используете в своём проекте связку Rx и ButterKnife?
Пилю собственное приложение и хотелось бы узнать мнение опытных программистов по поводу связок библиотек для написания структурированного, красивого кода.
На данный момент в проекте есть GSON, ...
2
голоса
0
ответов
44
показа
Как избежать слишком частого повторного рендера RecyclerView при использовании Flowable (RxJava)?
Реализую MVVM с room + flowable из rxjava + retrofit2.
При открытии активити из репозитория мне прилетает FLowable со списком элементов из БД (room).
В этот же момент репозиторий запрашивает список у ...
3
голоса
2
ответа
122
показа
Уведомление из Room пустым списком - Flowable из Room
Необходимо получать из репозитория все выбранные объекты (isSelected).
Есть DataRepository - который возвращает Flowable<List<Data>>, данные беру из Room`а:
fun getSelectObjects(): ...
2
голоса
1
ответ
64
показа
Объединение данных с нескольких репозиториев
Есть несколько репозиториев
ObjectRep - объекты
ObjTypeRep - описание типов объектов
TreeRep - дерево вложенностей
MotionRep - текущие параметры/состояние объекта (данных может и не быть)
На ...
0
голосов
1
ответ
507
показов
RxJava как дождаться выполнения запроса в RxJava и во время выполнения не вызывать его снова?
Вопрос в следующем, как дождаться выполнения запроса в RxJava и во время выполнения не вызывать его снова?
Или же например вызывать, но обрабатывать результат только последнего, а предыдущих ...
1
голос
1
ответ
217
показов
Как работает метод notifyDataSetChanged() в RecyclerView
Обновляю с помощью ретрофит список товаров, уведомляю о событии. В классе MainActivity вызываю метод notifyDataSetChanged(), что обычно приводит к обновлению списка в RecyclerView. Но никаких ...
0
голосов
1
ответ
17
показов
Доработать скрипт на проверку option
Помогите, пожалуйста, доработать скрипт.
Есть список категорий, и есть информация, которая скрыта, при выборе определенной категории, скрытый блок показывается. Якобы все хорошо, но есть маленькое "НО"...
0
голосов
1
ответ
63
показа
RxJava преобразовать две модели в одну
Получаю курс иностранных валют к рублю https://www.cbr.ru/scripts/XML_daily.asp?date_req=28/03/2020
Модель ответа с сервера:
public class RateCurrencyResponseModel {
private String id;
...
1
голос
1
ответ
322
показа
Как вернуть значение из Observable в Rxjava 2 [закрыт]
Я столкнулся с проблемой, что onNext не может содержать return, но мне нужно вернуть строку.
Запрос сделан с помощью Retrofit с фабрикой внутри интерфейса (ApiService).
fun getNameAnimal(name : ...
0
голосов
2
ответа
2k
показов
В чем отличие Single от Observable в RxJava?
Друзья! В чем различие Single и Observable? Не понятно, когда использовать Observable вместо Single, во всех обычных операциях получение с БД данных или из сети всегда один запрос, а значит всегда ...