Вопросы с меткой [rxjava2]
Руководство по использованию метки rxjava2 отсутствует.
71
вопрос
2
голоса
1
ответ
40
показов
Как синхронизировать два асинхронных потока в rxJava2
Учусь работать в AndroidStudio, только начал изучать RxJava2. Сейчас пытаюсь сделать маленькое приложение с PokeAPI. Проблема следующая, получаю количество покемонов и их имя с API в одном потоке, а ...
1
голос
1
ответ
23
показа
Бесконечный цикл при обновлении в room с использованием rxJava
Все я заккоментил, чтобы найти источник зла.
model.updateFavorite(it) он входит в бесконечный цикл.
Его код
fun updateFavorite(pokemon: PokemonEntity){
Log.d("RefreshFavorite", ...
0
голосов
1
ответ
39
показов
Закрытие подписки disposable в Rxjava в Android
Недавно на код ревью услышал от сеньора, что типа подписку Rxjava закрывать необязательно во вью модели, так как модель умрёт и подписка вместе с ней, а до тех пор она все равно ещё нужна или там один ...
0
голосов
1
ответ
27
показов
Узнать что от Observable отписались все подписчики
Есть репозиторий NfcRepository
хотел внутри сделать метод который возвращает состояние самого модуля (а также изменения состояния)
fun getNfcState(): Observable<NfcState>
Есть два варианта:
...
0
голосов
2
ответа
49
показов
Как вызвать onError после filter()
Мой observable генерирует случайное число от 1 до 5. Я фильтрую числа, чтобы они не были равны 4. Какие есть способы вызвать метод onError внутри активити, если значение будет равно 4? Проверять ...
1
голос
1
ответ
25
показов
Обработка не всех запросов к Retrofit2
я получаю список состава индекса (102 тикера) и хочу узнать о них детальную информацию, но из 102 запросов выполняется всегда не больше 10 и причем рандомно выбирается тикер. Все запросы выполняю ...
2
голоса
1
ответ
58
показов
Показать ошибку нет интернета используя Retrofit 2 и RxJava
для получения данных с сервера использую вот такой запрос:
public void getContactDataTechnicalSupport(String country) {
compositeDisposable = new CompositeDisposable();
ApiFactory ...
0
голосов
1
ответ
111
показов
В каком потоке выполняется subscribe() в RxJava?
У меня есть метод getText(), который получает из сети текст. Его нужно вставить в TextView.
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
...
0
голосов
0
ответов
37
показов
Остановить основной поток, пока не закончится загрузка в другом(Observable)
Всем привет!
Очень нужна помощь.
Ниже указан код, который выполняется одновременно с главным потоком. Мне нужно сделать так чтобы он закончио выполняться и только после программа продолжила ...
1
голос
1
ответ
37
показов
Как получить и объединить данные полученные с сервера? С первого запроса я получаю список с url, а после я должен по каждому url получить данные
Получаю список с https://api.github.com/repositories, но в элементе списка нужно показать дополнительную информацию которая берется https://api.github.com/repos/<REPO_full_name>. Как мне ...
1
голос
1
ответ
29
показов
Загадочное поведение Flowable с flatMap
Не могу понять, почему, в случае, если я вызываю метод showcaseFlatMap со следующим кодом :
fun showcaseFlatMap() {
val colors: Flowable<String> = Flowable.just("orange", "...
0
голосов
0
ответов
55
показов
При использовании RxJava обновления подписчику не приходят
Я только начал изучать RxJava и столкнулся с проблемой.
У меня есть метод который делает запрос в Firebase Storage и при удачном исходе возвращает Observable(Uri)
public Observable<Uri> get() {
...
0
голосов
1
ответ
40
показов
Unit Test непонятный результат при тесте RX Java
Есть вот такой тест.
@Test
fun needShowOnboarding() {
val cards = listOf(
mockCard(cardUcid = "1", pinSet = false),
mockCard(cardUcid = "2", pinSet = true),
...
1
голос
1
ответ
35
показов
Как реагировать на колбэки из другого класса RxJava
У меня есть метод toLogin в презенторе, который должен авторизовывать пользователя и вызывать соответствующие методы у Activity:
@Override
public void toLogin(String email, String password) {
if(!...
0
голосов
1
ответ
279
показов
RxJava как дождаться выполнения запроса в RxJava и во время выполнения не вызывать его снова?
Вопрос в следующем, как дождаться выполнения запроса в RxJava и во время выполнения не вызывать его снова?
Или же например вызывать, но обрабатывать результат только последнего, а предыдущих ...
0
голосов
1
ответ
189
показов
Как сделать поочередную загрузку данных с помощью kotlin coroutines?
С помощью rxjava в классе репозитория я делал так:
private val scheduler = Schedulers.single()
fun callApiMethod(args):Single<ResultType>{
return apiMethod(args).subscribeOn(scheduler)
}
...
0
голосов
2
ответа
963
показа
В чем отличие Single от Observable в RxJava?
Друзья! В чем различие Single и Observable? Не понятно, когда использовать Observable вместо Single, во всех обычных операциях получение с БД данных или из сети всегда один запрос, а значит всегда ...
0
голосов
0
ответов
65
показов
Как установить в базу данных Room данные из API?
Нужно при запуске приложения получить данные от Api и добавить их в БД Room. Дальше список из БД должен отображаться в RecyclerView. Проблема в том, что когда я пытаюсь добавить данные в БД с помощью ...
1
голос
1
ответ
53
показа
Чистая архитектура, как отделить работу с сетью (Куда вынести логику проверки токена)?
У юзера есть Token который в любой момент времени может стать не валидным.
Понятно что токен проверять в doOnEvent не вариант (дубликация кода в каждом запросе) и не понимаю как и куда вынести логику ...
0
голосов
1
ответ
72
показа
Rx combineLatest не понимаю почему ошибка
Пытаюсь создать комбинирующую функцию с помощью Rx. Делал так много раз никогда не было проблем.
fun getCategories(): Observable<ArrayList<String>> {
return Observable....
0
голосов
0
ответов
37
показов
Обновление данных раз в N секунд
Есть локальный источник данных:
Observable<Data> getData();
Есть запрос, чтобы их обновить:
Completable updateData();
Хочу чтобы данные начинали обновляться раз в N секунд, если на них ...
0
голосов
1
ответ
34
показа
Отловить ошибку в concat RxJava
Например, есть локальный репозиторий и сетевой
Observable.concat(
localDao.getAll().firstElement().toObservable(),
api.get()
.filter(Checker::...
1
голос
1
ответ
51
показ
Flowable не реагирует на отсутствие элемента в БД Room
В этой статье написано:
Here’s how the Flowable/Observable behaves:
When there is no user in the database and the query returns no rows,
the Flowable will not emit, neither onNext, nor ...
3
голоса
1
ответ
324
показа
Что выполняют CallAdapterFactory в Retrofit?
.addCallAdapterFactory(RxJava2CallAdapterFactory.create())
1
голос
1
ответ
53
показа
Комбинация нескольких методов в RXJava2
Дело в том, что мне необходимо одновременно подтягивать данные из локальной базы, с сервера, при этом проверять подключение к интернету.
Без проверки интернета получается легко. Но при отключении ...
0
голосов
0
ответов
107
показов
Как записать во внешнюю переменную значение полученное в Observable в RxJava2?
Не могу записать в переменную typesOfResponsibility значение it, полученное из Observable.fromCallable при подписке subscribe
fun getById(id: Int) : TypesOfResponsibility {
var ...
0
голосов
1
ответ
200
показов
как из метода subscribe вернуть observable значение в rxjava2?
Идея такова:
Вставляю список в БД, подписываюсь на вставку, при успешной вставке, возвращается список id вставленных элементов, по этому списку id прохожусь в цикле и получаю строки по id, записываю ...
2
голоса
2
ответа
163
показа
Получение и обработка данных в фоне при помощи RxJava
Начал разбираться с RxJava. Информации очень много и пока сложно понять, что именно использовать. Нужна помощь, чтобы разобраться.
Задача: Получить данные из трех разных источников, объединить, ...
1
голос
1
ответ
167
показов
Проблеммы с подключением Rxjava 2 на Android Studio
Я прописываю в grad:
classpath 'io.reactivex.rxjava2:rxjava:2.2.8'
Андройд студио что то подключает, закачивает, пишет успешно. После Я пытаюсь применить простой
Observable<String> ...
0
голосов
1
ответ
25
показов
Возврат параметров в Exception
Метод itemRepository.sendItem(it.item!!) возвращает
Flowable<Response<Item>>
Как сделать чтобы если при выполнении itemRepository.sendItem возникнет ошибка, в Throwable чтобы падали ...
0
голосов
0
ответов
114
показов
RxJava + Retrofit + Observable цикл запросов
Имеется база из которой с помощью запросов достаются данные в формате json.
Первый запрос возвращает массив объектов, в котором есть поле с внешним ключом к другой таблице, из которой нужно достать ...
0
голосов
2
ответа
60
показов
Проблема со строкой, jsonAPIDetail.setLogin(arguments?.getString("userLogin")!!) - IllegalArgumentException: Service methods cannot return void
Класс User
class User {
var login : String = ""
var id : Int = 0
var avatar_url : String = ""
var followers : Int = 0
var name : String = ""
var public_repos : Int = 0
var public_gists : Int = 0 }
...
1
голос
1
ответ
245
показов
Как объединить два Single в rxjava?
Метод itemDao.findItemsByDetails() возвращает Single<List<Int> после выполнения которого мы начинаем выполнять метод getItemsByIds(), который уже возвращает Flowable<MutableList<Item>...
0
голосов
1
ответ
156
показов
Подписка на метод внутри Flatmap Rx Java
Всем доброго времени суток!
В ходе изучения и использования RxJava возникло непонимание в использовании метода flatmap.
Цель: выполнить последовательно цепочку вызовов с отслеживанием ошибок
...
1
голос
1
ответ
158
показов
Android, отписка от BehaviorSubject
У меня есть BehaviorSubject, назначение которого - наблюдать за int переменной:
private BehaviorSubject<Integer> source = BehaviorSubject.create();
В onCreate я подписываюсь на него:
source....
1
голос
1
ответ
46
показов
Как повторно заэмитить элементы из первой последовательности если у второй вызван OnNext
При открытии приложения репозиторий возвращает Observable:
fun role(): Observable<Triple<Role, Boolean, List<Int>>> {
return repository
.data()
.map {
...
0
голосов
1
ответ
39
показов
RxJava2 range() метод не работает в Andoid
Документация:
"The Range operator emits a range of sequential integers, in order, where you select the start of the range and its length".
Насколько я понимаю, должно быть последовательное ...
0
голосов
1
ответ
184
показа
RxJava merge параллельное выполнение
Не удается запустить параллельно два Observable через merge.
class MyExample {
//Создание observable
public static Observable<String> createObservable(String name){
return ...
1
голос
1
ответ
35
показов
Получение результата запроса RxJava2 + Room
Не могу разобраться с получением данных после запроса, в конечном итоге необходимо вернуть объект Note, но как это написать не понимаю, бьюсь над проблемой не первый день.
При всех попытках получить ...
0
голосов
2
ответа
97
показов
RxJava2. Как вернуть Observable<Object> из метода, который возвращает void?
Метод takePicture(...) из android.hardware.Camera имеет тип возвращаемого значения void
public final void takePicture(ShutterCallback shutter, PictureCallback raw, PictureCallback jpeg) {
...
0
голосов
0
ответов
33
показа
rxJava + Retrofit2 Получить актуальные данные
Делаю запрос
@SuppressLint("CheckResult")
private Observable<Exchange> kursRequest(){
String base = exchange.getBase();
String symbols=symbolsWaluta;
return request(...
3
голоса
1
ответ
4k
показов
Объясните RxJava2. Disposable
Пишу android приложение. Начал использовать RxJava2 и RxAndroid2. Но во многих вещах еще нет четкого понимания.
Реализовал обращение к API через Retrofit2 которое возвращает Observable<List<...
1
голос
1
ответ
159
показов
Android RxJava можно ли вернуть из .subscribe() еще один Observable<>
Используем (Android приложение):
implementation group: 'io.reactivex.rxjava2', name: 'rxjava', version: '2.1.16'
implementation group: 'io.reactivex.rxjava2', name: 'rxandroid', version: '2.0.2'
...
3
голоса
2
ответа
87
показов
Возможен ли реактивный маршалинг (marshaling) xml в java-объект?
Я делаю запрос на определенный сервис который отдаем мне очень медленно большой xml
Мне нужно не дожидаясь полного ответа документа начать читать и преобразовывать некоторые элементы xml в java-...
0
голосов
0
ответов
61
показ
Как правильно собрать Maybe RxJava2?
Работаю с Room есть вот такой метод
@Query("SELECT * FROM mytable WHERE pnr = :iPnr")
abstract Maybe<UserPnrDbObject> getBy(String iPnr);
и есть вот такой метод
public Maybe<UserActivePnr&...
1
голос
1
ответ
161
показ
Как мне из Observable<io.rxjava> сохранить данные в List<>?
Есть метод, который получает данные из json и создает Observable<>, из него мне нужно получить данные и сохранить в List<>:
@NonNull
public Observable<List<BaseProducts>> ...
0
голосов
1
ответ
17
показов
Таймер получения эмиссии
Есть источник данных.
Требуется выполнять действие если источник данных не эмиттил айтем за 3 секунды.
введите сюда кодLog.d("MAESTRO", "before: ");
ConnectableObservable.just(...
0
голосов
1
ответ
59
показов
Как собрать Maybe<List<User>> из Maybe<User>?
Есть у меня метод
Maybe<User> getUser(int iId){}
и есть метод
Maybe<List<User>> getUsers(List<Integer> iIds){}
Вопрос: как реализовать этот метод?
0
голосов
1
ответ
160
показов
Задача на rxJava
У нас есть Observable<Int> который эммитит разные числа. Нам надо встать между Observable и подписчиком и смотреть когда к нам в onNext приходит число "x" то мы увеличиваем счетчик на единицу и ...
5
голосов
0
ответов
107
показов
Как правильно составить очередь в rxJava и ретрофит
Я использую ретрофит2 и рх2
Мое приложение раз в секунду делает запрос на сервер
Я хочу эти запросы поставить в синхронную очередь, так чтоб они выполнялись один за другим по мере поступления в ...