Skip to main content

Вопросы с меткой [rxjava]

Java реализация ReactiveX, являющегося API для асинхронного программирования посредством наблюдения за потоками событий

Фильтрация
Сортировка
Метки
0 голосов
0 ответов
35 показов

Как работают Reactive Streams java?

В целом разобрался с механизмом работы Reactive Streams, но не понимаю момент, когда подписчик вызывает метод request(n) подписки(Subscription), чтобы запросить данные у издателя, как тот понимает, ...
Aleksandr's user avatar
  • 101
2 голоса
1 ответ
48 показов

Почему subscribeOn() не отправляет предыдущее значение из Behaviour subject?

Изучаю нюансы работы методов subscribeOn() / observeOn() для Subjects. Не могу понять, почему в приведенном коде subscribeOn() запрещает отправку события str 0? val observer: Observer<String&...
Novikov's user avatar
  • 111
1 голос
0 ответов
34 показа

Статус подключения к серверу с помощью rxjava в Android

Имею подключение по websocket object StompWrapper { private var emitter: ObservableEmitter<Event>? = null init { val client = OkHttpClient.Builder().build() val stomp = ...
iormark's user avatar
  • 181
1 голос
1 ответ
57 показов

Бесконечный цикл при обновлении в room с использованием rxJava

Все я заккоментил, чтобы найти источник зла. model.updateFavorite(it) он входит в бесконечный цикл. Его код fun updateFavorite(pokemon: PokemonEntity){ Log.d("RefreshFavorite", ...
Gorge Flow's user avatar
0 голосов
1 ответ
64 показа

Как сделать вызов асинхронным rxJava

У меня сейчас стоит задача получить список данных из интернета, через retrofit. И если код ответа не успешный(200), то взять этот список данных из бд(room). Как мне сделать это правильно с rxJava? Я ...
Gorge Flow's user avatar
1 голос
1 ответ
101 показ

Когда отписываться от Observable?

Доброго времени суток ! пытаюсь разобраться со связкой RxJava + Retrofit в интерфейсе retrofit есть метод возвращающий Single @GET fun getPicture(@Url url: String): Single<ResponseBody> ...
Bodigard's user avatar
0 голосов
1 ответ
36 показов

Какую аннотацию поставить в функции интерфейса Dao для Rxjava

У меня есть две функции находящиеся в Dao для работы с Rxjava надо пометить аннотацией Single,Completable и т.д. ,но мне выдает ошибку error: Not sure how to convert a Cursor to this method's return ...
REAPER's user avatar
  • 5
0 голосов
1 ответ
909 показов

Java Observer и Observable

Только начинаю погружение в Java. Не могу понять один момент, можем ли мы использовать один наблюдатель - Observer для разных объектов наблюдения - Observable или должно быть строго, один Observer ...
AlexHuck's user avatar
0 голосов
0 ответов
44 показа

Как подписаться на два observable разного типа за раз? rxjava

У меня есть два observable разного типа. val urlContent = contentRepo.getUrlContent(urls).toObservable() val isConnected = Observable.interval(1, TimeUnit.SECONDS).flatMap { ...
Илья Вишняк's user avatar
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 -> ...
NeckNecson's user avatar
0 голосов
1 ответ
56 показов

RxJava сортировка списка по одну из эллементов

Имею json из такими строками как title, time, click_url, img, type, top и тд. Я получаю список эллеметов со строками которые я описал выше. Мне нужно Получить список эллеметов который будет иметь ...
Vlad Bulan's user avatar
1 голос
0 ответов
31 показ

RxJava - как реактивно подставлять наблюдаемые значения (в т.ч. пары) в запрос в Room, который так же возвращает Observable?

Во вьюМодели: val searchQuery = Observable<String> val catNumberOnlyTurnedoff = Observable<Pair<Int, Boolean>> fun getWords(query: String, category: Int, onlyOff: Boolean) : ...
Alex Rodionow's user avatar
0 голосов
1 ответ
106 показов

Не могу получить данные из LiveData в UI

я новичок в Андроид. Во ViewModel использую liveData(temperature) в которую передаю данные из сервера при помощи RxJava. class WeatherTodayViewModel(application: Application) : AndroidViewModel(...
Kalinin's user avatar
0 голосов
1 ответ
135 показов

Как правильно реализовать цепочку rxjava в android kotlin?

Я пытаюсь реализовать условия отсутствия интернета на мобильном устройстве. При этом должна происходить такая последовательность операций в цепочке: 1.Проверяем время последнего запроса 2.Делаем ...
Евгений Колесник's user avatar
1 голос
1 ответ
77 показов

Несколько Api запросов с использованием RxJava и Retrofit

Такой вот вопрос. Мне нужно сделать несколько Api запросов с использованием Retrotit и RxJava. В первом запросе я получаю список из 20 фильмов. Мне нужно выводить список фильмов и инфу под каждым ...
Artem's user avatar
  • 67
0 голосов
1 ответ
57 показов

Синхронный RxJava запрос

У меня есть OkHttp Interceptor, который добавляет headers к запросам. Проблема в том, что он делает это асинхронно(использую RxJava2) и запрос уходить до модификации Interceptor. Код Interceptor: ...
dbuzin's user avatar
  • 133
0 голосов
1 ответ
54 показа

Обьеденить в один метод запрос с серва и запись в базу данных

У меня есть запрос из серва и из базы данных, суть в том, что бы при кадом запуске шла загрузка с базы данных, и с сервера который обновляет эту базу с помощью RxJava 2 Код который я придумал, но ...
Svetl9chok's user avatar
1 голос
1 ответ
39 показов

Завершение стримов RxJava при закрытии активности в Android

Разбираюсь с использованием RxJava в Android, возник вопрос следующего рода. Я сделал вот такую extension функцию: fun <T: View> T.setReactiveOnClickListener(): Flowable<View> { val ...
Олег Вялкин's user avatar
0 голосов
0 ответов
39 показов

RecyclerView, видя два одинаковых подряд объекта, автоматически смещает "камеру" на второй, оставляя впередиидущий сверху вне поля видимости

In the Fragment: @AndroidEntryPoint class DrillerFragment : Fragment(R.layout.cardstack_layout), CardStackListener { private val viewModel: DrillerViewModel by viewModels() private lateinit ...
Alex Rodionow's user avatar
0 голосов
2 ответа
56 показов

Как вызвать onError после filter()

Мой observable генерирует случайное число от 1 до 5. Я фильтрую числа, чтобы они не были равны 4. Какие есть способы вызвать метод onError внутри активити, если значение будет равно 4? Проверять ...
ianbelow's user avatar
0 голосов
1 ответ
59 показов

Дублирование ответов от Retrofit 2

я столкнулся с такой проблемой. Я делаю 2 запроса к внешнему API через Retrofit 2 + RxJava 3, но вместо одной строчки ответа они выводят по две. (Если сделать 3 запроса то каждый из них выведет по три ...
Melowetty's user avatar
0 голосов
0 ответов
40 показов

Мерцает textView при обновлении с помощью rxJava

Есть фрагмет с таким кодом StringObservable.from(inputStream) .subscribeOn(Schedulers.io()) .map(String::new) .map(s-> { Log.d(&...
Veles's user avatar
  • 1
1 голос
0 ответов
59 показов

Retrofit2 + RxJava. Зачем?

У меня два вопроса: Зачем использовать RxJava при работе с Retrofit2? Единственная причина что я находил - удобство обработки. Если опустить это преимущество, то так ли нужна RxJava сейчас в ...
Алексей Герман's user avatar
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:...
Alex Rodionow's user avatar
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 ...
Alex Rodionow's user avatar
0 голосов
0 ответов
99 показов

Перенос логики синхронизации с Kotlin корутин на iOS Swift в связке RxSwift+RxAlamofire

Есть некий функционал синхронизации, который хорошо рализован на корутинах. Код-пример ниже: class SyncExample { companion object { const val TAG = "SyncExample" val progress: ...
beeline09's user avatar
  • 161
1 голос
0 ответов
82 показа

RxJava2 + Retrofit2: Почему в интерфейсе Retrofit часто используют именно Observable/Flowable?

Читал разные статьи и смотрел много видео на ютубе по связке RxJava и Retrofit, и очень часто видел примерно одну и ту же конструкцию: @GET("some/endpoint") fun getSomeData(): Observable<...
Stenol_53's user avatar
  • 111
1 голос
1 ответ
91 показ

Реализация мгновенного поиска c RxJava

Пытаюсь делать в своем приложении мгновенный поиск пользователей из удаленной БД с RxJava. Следуя по одной статьи получилось сделать так: Сначала мне приходится получить всех пользователей,а потом ...
STRATEG 766's user avatar
0 голосов
1 ответ
349 показов

В каком потоке выполняется subscribe() в RxJava?

У меня есть метод getText(), который получает из сети текст. Его нужно вставить в TextView. protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); ...
senior salaga's user avatar
2 голоса
0 ответов
39 показов

Тестирование аргументов переданных в Observable RxJava

Есть некий метод: repository.get(arg1, arg2, arg3) Который возвращает Single<List<SomeObject>> Мне нужно протестировать, что на этот Single происходит подписка. Как протестировать ...
Sergei Buvaka's user avatar
1 голос
1 ответ
260 показов

Android MVVM как получить ответ от ViewModel во View

У меня есть активити, у нее есть viewmodel. Viewmodel во время инициализации скачивает с сервера с помощью retrofit данные в json. Эти данные преобразуются в список объектов во viewmodel. И теперь мне ...
Илья Кузьмич's user avatar
0 голосов
1 ответ
94 показа

WorkManager vs Rxjava

В чем разница между WorkManager и Rxjava? При каких обстоятельствах что использовать (примеры задач, пожалуйста)?
senior salaga's user avatar
1 голос
1 ответ
90 показов

RxJava map vs Kotlin map

Раньше когда был Java 6 и Rx, при использовании RX подхода, делал mapping так Single.just(listOf("1", "2", "3", "4")) .toObservable() ....
DuosDuo's user avatar
  • 1,640
1 голос
1 ответ
80 показов

Как правильно сделать асинхронные запросы, зависящие друг от друга RxJava Android

я новичек в RxJava. Задача следующая: есть 3 запроса Получение токена Валидация токена Получение id сессии Каждый запрос зависит от ответа предыдущего, т.е. сначала я делаю запрос на получение ...
Stenol_53's user avatar
  • 111
0 голосов
0 ответов
76 показов

При использовании RxJava обновления подписчику не приходят

Я только начал изучать RxJava и столкнулся с проблемой. У меня есть метод который делает запрос в Firebase Storage и при удачном исходе возвращает Observable(Uri) public Observable<Uri> get() { ...
senior salaga's user avatar
0 голосов
0 ответов
28 показов

По какой причине GSON может отдавать null?

Имеется стандартная связка в виде API Service (Retrofit + RxJava2CallAdapterFactory, GsonConverterFactory). Почему-то подписка сыпалась с null pointer в onError. Стал разбираться. Оказывается, null ...
newbibi's user avatar
0 голосов
1 ответ
82 показа

Как получить данные из БД Room с помощью RxJava если с удаленного сервера пришла ошибка

Всем привет. Пишу приложение в котором запрашивается погода с удаленного сервера. Для Api запроса использую библиотеку Retrofit и RxJava. Сейчас мне нужно добавить в приложение БД Room, если при Api ...
Artem's user avatar
  • 67
1 голос
0 ответов
60 показов

Подписка на обновления на сервере RxJava

В приложении на сервер загружается картинка. Эту картинку надо скачать и отобразить, но проблема в том, что она ещё не успевает загрузиться в базу данных. Хочу исправить это с помощью RxJava. Читал,...
senior salaga's user avatar
1 голос
1 ответ
312 показов

Android RxJava: как правильно подписать PublishSubject на множество Observable?

Буду благодарен за любые подсказки и варианты как это поправить. Задача: выдавать результаты вычислений асинхронно, по готовности. Пример составлен для теста из рабочего кода, его можно использовать в ...
white-imp's user avatar
  • 601
0 голосов
1 ответ
92 показа

не сохраняются данные в переменную в методе subscribe() RxJava

Всем привет. Не могу понять почему в теле метода subscrube() я присваиваю значение переменной coordinates,и сразу же вывожу значение переменной coordinates в Log и мне отображает нужный мне результат ...
Artem's user avatar
  • 35
1 голос
1 ответ
54 показа

Как вы используете в своём проекте связку Rx и ButterKnife?

Пилю собственное приложение и хотелось бы узнать мнение опытных программистов по поводу связок библиотек для написания структурированного, красивого кода. На данный момент в проекте есть GSON, ...
kernokus's user avatar
  • 250
2 голоса
0 ответов
44 показа

Как избежать слишком частого повторного рендера RecyclerView при использовании Flowable (RxJava)?

Реализую MVVM с room + flowable из rxjava + retrofit2. При открытии активити из репозитория мне прилетает FLowable со списком элементов из БД (room). В этот же момент репозиторий запрашивает список у ...
sholkyman's user avatar
3 голоса
2 ответа
122 показа

Уведомление из Room пустым списком - Flowable из Room

Необходимо получать из репозитория все выбранные объекты (isSelected). Есть DataRepository - который возвращает Flowable<List<Data>>, данные беру из Room`а: fun getSelectObjects(): ...
DuosDuo's user avatar
  • 1,640
2 голоса
1 ответ
64 показа

Объединение данных с нескольких репозиториев

Есть несколько репозиториев ObjectRep - объекты ObjTypeRep - описание типов объектов TreeRep - дерево вложенностей MotionRep - текущие параметры/состояние объекта (данных может и не быть) На ...
DuosDuo's user avatar
  • 1,640
0 голосов
1 ответ
507 показов

RxJava как дождаться выполнения запроса в RxJava и во время выполнения не вызывать его снова?

Вопрос в следующем, как дождаться выполнения запроса в RxJava и во время выполнения не вызывать его снова? Или же например вызывать, но обрабатывать результат только последнего, а предыдущих ...
Anocean's user avatar
  • 75
1 голос
1 ответ
217 показов

Как работает метод notifyDataSetChanged() в RecyclerView

Обновляю с помощью ретрофит список товаров, уведомляю о событии. В классе MainActivity вызываю метод notifyDataSetChanged(), что обычно приводит к обновлению списка в RecyclerView. Но никаких ...
stepan1995's user avatar
0 голосов
1 ответ
17 показов

Доработать скрипт на проверку option

Помогите, пожалуйста, доработать скрипт. Есть список категорий, и есть информация, которая скрыта, при выборе определенной категории, скрытый блок показывается. Якобы все хорошо, но есть маленькое "НО"...
Дмитрий's user avatar
0 голосов
1 ответ
63 показа

RxJava преобразовать две модели в одну

Получаю курс иностранных валют к рублю https://www.cbr.ru/scripts/XML_daily.asp?date_req=28/03/2020 Модель ответа с сервера: public class RateCurrencyResponseModel { private String id; ...
artur_mm's user avatar
1 голос
1 ответ
322 показа

Как вернуть значение из Observable в Rxjava 2 [закрыт]

Я столкнулся с проблемой, что onNext не может содержать return, но мне нужно вернуть строку. Запрос сделан с помощью Retrofit с фабрикой внутри интерфейса (ApiService). fun getNameAnimal(name : ...
Funrab's user avatar
  • 13
0 голосов
2 ответа
2k показов

В чем отличие Single от Observable в RxJava?

Друзья! В чем различие Single и Observable? Не понятно, когда использовать Observable вместо Single, во всех обычных операциях получение с БД данных или из сети всегда один запрос, а значит всегда ...
Димончик's user avatar