Вопросы с меткой [rxjava2]
Руководство по использованию метки rxjava2 отсутствует.
74
вопроса
1
голос
0
ответов
27
показов
Статус подключения к серверу с помощью rxjava в Android
Имею подключение по websocket
object StompWrapper {
private var emitter: ObservableEmitter<Event>? = null
init {
val client = OkHttpClient.Builder().build()
val stomp = ...
0
голосов
0
ответов
52
показа
Переписать код с RxJava на Kotlin flow
У меня есть код с использованием RxJava:
private val refresh = PublishProcessor.create<Any>().toSerialized()
...
Single.fromCallable {
val number = 1
return@fromCallable number
}....
0
голосов
0
ответов
40
показов
Повторить запрос при 202 коде Android Kotlin
Мне нужно реализовать повтор запроса если приходит 202 код используя RxJava 2, проблема в том что когда я пытаюсь это сделать, то при 202 коде в ответе от сервера пусто, а при успешном ответе приходит ...
2
голоса
1
ответ
91
показ
Как синхронизировать два асинхронных потока в rxJava2
Учусь работать в AndroidStudio, только начал изучать RxJava2. Сейчас пытаюсь сделать маленькое приложение с PokeAPI. Проблема следующая, получаю количество покемонов и их имя с API в одном потоке, а ...
1
голос
1
ответ
46
показов
Бесконечный цикл при обновлении в room с использованием rxJava
Все я заккоментил, чтобы найти источник зла.
model.updateFavorite(it) он входит в бесконечный цикл.
Его код
fun updateFavorite(pokemon: PokemonEntity){
Log.d("RefreshFavorite", ...
0
голосов
1
ответ
99
показов
Закрытие подписки disposable в Rxjava в Android
Недавно на код ревью услышал от сеньора, что типа подписку Rxjava закрывать необязательно во вью модели, так как модель умрёт и подписка вместе с ней, а до тех пор она все равно ещё нужна или там один ...
0
голосов
1
ответ
46
показов
Узнать что от Observable отписались все подписчики
Есть репозиторий NfcRepository
хотел внутри сделать метод который возвращает состояние самого модуля (а также изменения состояния)
fun getNfcState(): Observable<NfcState>
Есть два варианта:
...
0
голосов
2
ответа
54
показа
Как вызвать onError после filter()
Мой observable генерирует случайное число от 1 до 5. Я фильтрую числа, чтобы они не были равны 4. Какие есть способы вызвать метод onError внутри активити, если значение будет равно 4? Проверять ...
1
голос
1
ответ
26
показов
Обработка не всех запросов к Retrofit2
я получаю список состава индекса (102 тикера) и хочу узнать о них детальную информацию, но из 102 запросов выполняется всегда не больше 10 и причем рандомно выбирается тикер. Все запросы выполняю ...
2
голоса
1
ответ
96
показов
Показать ошибку нет интернета используя Retrofit 2 и RxJava
для получения данных с сервера использую вот такой запрос:
public void getContactDataTechnicalSupport(String country) {
compositeDisposable = new CompositeDisposable();
ApiFactory ...
0
голосов
1
ответ
220
показов
В каком потоке выполняется subscribe() в RxJava?
У меня есть метод getText(), который получает из сети текст. Его нужно вставить в TextView.
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
...
0
голосов
0
ответов
74
показа
Остановить основной поток, пока не закончится загрузка в другом(Observable)
Всем привет!
Очень нужна помощь.
Ниже указан код, который выполняется одновременно с главным потоком. Мне нужно сделать так чтобы он закончио выполняться и только после программа продолжила ...
1
голос
1
ответ
41
показ
Как получить и объединить данные полученные с сервера? С первого запроса я получаю список с url, а после я должен по каждому url получить данные
Получаю список с https://api.github.com/repositories, но в элементе списка нужно показать дополнительную информацию которая берется https://api.github.com/repos/<REPO_full_name>. Как мне ...
1
голос
1
ответ
31
показ
Загадочное поведение Flowable с flatMap
Не могу понять, почему, в случае, если я вызываю метод showcaseFlatMap со следующим кодом :
fun showcaseFlatMap() {
val colors: Flowable<String> = Flowable.just("orange", "...
0
голосов
0
ответов
63
показа
При использовании RxJava обновления подписчику не приходят
Я только начал изучать RxJava и столкнулся с проблемой.
У меня есть метод который делает запрос в Firebase Storage и при удачном исходе возвращает Observable(Uri)
public Observable<Uri> get() {
...
0
голосов
1
ответ
58
показов
Unit Test непонятный результат при тесте RX Java
Есть вот такой тест.
@Test
fun needShowOnboarding() {
val cards = listOf(
mockCard(cardUcid = "1", pinSet = false),
mockCard(cardUcid = "2", pinSet = true),
...
1
голос
1
ответ
38
показов
Как реагировать на колбэки из другого класса RxJava
У меня есть метод toLogin в презенторе, который должен авторизовывать пользователя и вызывать соответствующие методы у Activity:
@Override
public void toLogin(String email, String password) {
if(!...
0
голосов
1
ответ
408
показов
RxJava как дождаться выполнения запроса в RxJava и во время выполнения не вызывать его снова?
Вопрос в следующем, как дождаться выполнения запроса в RxJava и во время выполнения не вызывать его снова?
Или же например вызывать, но обрабатывать результат только последнего, а предыдущих ...
0
голосов
1
ответ
242
показа
Как сделать поочередную загрузку данных с помощью kotlin coroutines?
С помощью rxjava в классе репозитория я делал так:
private val scheduler = Schedulers.single()
fun callApiMethod(args):Single<ResultType>{
return apiMethod(args).subscribeOn(scheduler)
}
...
0
голосов
2
ответа
2k
показов
В чем отличие Single от Observable в RxJava?
Друзья! В чем различие Single и Observable? Не понятно, когда использовать Observable вместо Single, во всех обычных операциях получение с БД данных или из сети всегда один запрос, а значит всегда ...
0
голосов
0
ответов
85
показов
Как установить в базу данных Room данные из API?
Нужно при запуске приложения получить данные от Api и добавить их в БД Room. Дальше список из БД должен отображаться в RecyclerView. Проблема в том, что когда я пытаюсь добавить данные в БД с помощью ...
1
голос
1
ответ
61
показ
Чистая архитектура, как отделить работу с сетью (Куда вынести логику проверки токена)?
У юзера есть Token который в любой момент времени может стать не валидным.
Понятно что токен проверять в doOnEvent не вариант (дубликация кода в каждом запросе) и не понимаю как и куда вынести логику ...
0
голосов
1
ответ
80
показов
Rx combineLatest не понимаю почему ошибка
Пытаюсь создать комбинирующую функцию с помощью Rx. Делал так много раз никогда не было проблем.
fun getCategories(): Observable<ArrayList<String>> {
return Observable....
0
голосов
0
ответов
57
показов
Обновление данных раз в N секунд
Есть локальный источник данных:
Observable<Data> getData();
Есть запрос, чтобы их обновить:
Completable updateData();
Хочу чтобы данные начинали обновляться раз в N секунд, если на них ...
0
голосов
1
ответ
35
показов
Отловить ошибку в concat RxJava
Например, есть локальный репозиторий и сетевой
Observable.concat(
localDao.getAll().firstElement().toObservable(),
api.get()
.filter(Checker::...
1
голос
1
ответ
55
показов
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
ответ
458
показов
Что выполняют CallAdapterFactory в Retrofit?
.addCallAdapterFactory(RxJava2CallAdapterFactory.create())
1
голос
1
ответ
57
показов
Комбинация нескольких методов в RXJava2
Дело в том, что мне необходимо одновременно подтягивать данные из локальной базы, с сервера, при этом проверять подключение к интернету.
Без проверки интернета получается легко. Но при отключении ...
0
голосов
0
ответов
127
показов
Как записать во внешнюю переменную значение полученное в Observable в RxJava2?
Не могу записать в переменную typesOfResponsibility значение it, полученное из Observable.fromCallable при подписке subscribe
fun getById(id: Int) : TypesOfResponsibility {
var ...
0
голосов
1
ответ
235
показов
как из метода subscribe вернуть observable значение в rxjava2?
Идея такова:
Вставляю список в БД, подписываюсь на вставку, при успешной вставке, возвращается список id вставленных элементов, по этому списку id прохожусь в цикле и получаю строки по id, записываю ...
2
голоса
2
ответа
191
показ
Получение и обработка данных в фоне при помощи RxJava
Начал разбираться с RxJava. Информации очень много и пока сложно понять, что именно использовать. Нужна помощь, чтобы разобраться.
Задача: Получить данные из трех разных источников, объединить, ...
1
голос
1
ответ
189
показов
Проблеммы с подключением Rxjava 2 на Android Studio
Я прописываю в grad:
classpath 'io.reactivex.rxjava2:rxjava:2.2.8'
Андройд студио что то подключает, закачивает, пишет успешно. После Я пытаюсь применить простой
Observable<String> ...
0
голосов
1
ответ
28
показов
Возврат параметров в Exception
Метод itemRepository.sendItem(it.item!!) возвращает
Flowable<Response<Item>>
Как сделать чтобы если при выполнении itemRepository.sendItem возникнет ошибка, в Throwable чтобы падали ...
0
голосов
0
ответов
125
показов
RxJava + Retrofit + Observable цикл запросов
Имеется база из которой с помощью запросов достаются данные в формате json.
Первый запрос возвращает массив объектов, в котором есть поле с внешним ключом к другой таблице, из которой нужно достать ...
0
голосов
2
ответа
76
показов
Проблема со строкой, 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
ответ
345
показов
Как объединить два Single в rxjava?
Метод itemDao.findItemsByDetails() возвращает Single<List<Int> после выполнения которого мы начинаем выполнять метод getItemsByIds(), который уже возвращает Flowable<MutableList<Item>...
0
голосов
1
ответ
187
показов
Подписка на метод внутри Flatmap Rx Java
Всем доброго времени суток!
В ходе изучения и использования RxJava возникло непонимание в использовании метода flatmap.
Цель: выполнить последовательно цепочку вызовов с отслеживанием ошибок
...
1
голос
1
ответ
186
показов
Android, отписка от BehaviorSubject
У меня есть BehaviorSubject, назначение которого - наблюдать за int переменной:
private BehaviorSubject<Integer> source = BehaviorSubject.create();
В onCreate я подписываюсь на него:
source....
1
голос
1
ответ
48
показов
Как повторно заэмитить элементы из первой последовательности если у второй вызван OnNext
При открытии приложения репозиторий возвращает Observable:
fun role(): Observable<Triple<Role, Boolean, List<Int>>> {
return repository
.data()
.map {
...
0
голосов
1
ответ
43
показа
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
ответ
230
показов
RxJava merge параллельное выполнение
Не удается запустить параллельно два Observable через merge.
class MyExample {
//Создание observable
public static Observable<String> createObservable(String name){
return ...
1
голос
1
ответ
38
показов
Получение результата запроса RxJava2 + Room
Не могу разобраться с получением данных после запроса, в конечном итоге необходимо вернуть объект Note, но как это написать не понимаю, бьюсь над проблемой не первый день.
При всех попытках получить ...
0
голосов
2
ответа
119
показов
RxJava2. Как вернуть Observable<Object> из метода, который возвращает void?
Метод takePicture(...) из android.hardware.Camera имеет тип возвращаемого значения void
public final void takePicture(ShutterCallback shutter, PictureCallback raw, PictureCallback jpeg) {
...
0
голосов
0
ответов
35
показов
rxJava + Retrofit2 Получить актуальные данные
Делаю запрос
@SuppressLint("CheckResult")
private Observable<Exchange> kursRequest(){
String base = exchange.getBase();
String symbols=symbolsWaluta;
return request(...
3
голоса
1
ответ
5k
показов
Объясните RxJava2. Disposable
Пишу android приложение. Начал использовать RxJava2 и RxAndroid2. Но во многих вещах еще нет четкого понимания.
Реализовал обращение к API через Retrofit2 которое возвращает Observable<List<...
1
голос
1
ответ
189
показов
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
ответа
105
показов
Возможен ли реактивный маршалинг (marshaling) xml в java-объект?
Я делаю запрос на определенный сервис который отдаем мне очень медленно большой xml
Мне нужно не дожидаясь полного ответа документа начать читать и преобразовывать некоторые элементы xml в java-...
0
голосов
0
ответов
69
показов
Как правильно собрать Maybe RxJava2?
Работаю с Room есть вот такой метод
@Query("SELECT * FROM mytable WHERE pnr = :iPnr")
abstract Maybe<UserPnrDbObject> getBy(String iPnr);
и есть вот такой метод
public Maybe<UserActivePnr&...
1
голос
1
ответ
176
показов
Как мне из Observable<io.rxjava> сохранить данные в List<>?
Есть метод, который получает данные из json и создает Observable<>, из него мне нужно получить данные и сохранить в List<>:
@NonNull
public Observable<List<BaseProducts>> ...
0
голосов
1
ответ
19
показов
Таймер получения эмиссии
Есть источник данных.
Требуется выполнять действие если источник данных не эмиттил айтем за 3 секунды.
введите сюда кодLog.d("MAESTRO", "before: ");
ConnectableObservable.just(...