Вопросы по теме 'rx-java2'
Android RxJava и цепочка наблюдаемых
Я пытаюсь связать несколько наблюдаемых вместе и выполнить некоторые действия в зависимости от того, какое наблюдаемое было выполнено. Но я столкнулся со странным поведением.
class MainActivity : AppCompatActivity() {
val TAG: String =...
502 просмотров
schedule
07.07.2022
Сгладить список в RxJava 2
Я использую RxJava 1 в течение некоторого времени, но я хочу взглянуть на RxJava 2. В RxJava 1 я мог бы выводить каждый элемент списка следующим образом:
List<String> list = ...
Observable.from(list)
.filter(str ->...
7970 просмотров
schedule
01.06.2022
Проблема загрузки параллельного файла Android Retrofit
В моем приложении есть вариант использования для загрузки двух zip-файлов с сервера. Для этого я использовал модификацию + rxjava (создал две отдельные службы модификации). Для параллельного выполнения я подписывался на услугу модернизации в новом...
627 просмотров
schedule
28.10.2022
OnErrorThrowable не найден в rxjava 2
Я обновляю rxjava 1 до rxjava 2. В rxjava 1 есть OnErrorThrowable, но его нет в rxjava 2. Что я могу сделать в следующем коде, чтобы заменить OnErrorThrowable?
static Observable<String> sampleObservable() {
return Observable.defer(new...
306 просмотров
schedule
27.03.2023
Как изменить параметры повторного запроса после ошибки в RxJava
Я отправляю запрос на вход на сервер с модификацией 2.0, и сервер возвращает токен сеанса клиента, который я должен использовать в других запросах, но этот токен имеет ограниченный срок службы, и когда срок его действия истекает, сервер возвращает...
2438 просмотров
schedule
16.05.2023
RxAndroid Release Apk не работает для сборки 25.0.2
Я разместил это на странице проблемы rxandroid , но ответа не было. 4 дня, но ответа нет, проблема в отладочном apk. Функции rxjava работают должным образом, но в релизном apk вообще не работают только функции, связанные с rxjava или rxandroid....
1396 просмотров
schedule
01.09.2022
flatMapFirst: flatMap, который добавляет новую наблюдаемую только в том случае, если предыдущая закончилась
Как реализовать оператор flatMapFirst , похожий на flatMap , но добавляющий новый наблюдаемый только в том случае, если предыдущий закончился? Если предыдущий все еще работает, он просто игнорирует новый наблюдаемый. Как это реализовать в RxJava...
953 просмотров
schedule
09.06.2023
RxJava: использование SubscribeOn приводит к выходу программы без завершения
Это мой пример кода
Observable.range(1,5)
.subscribeOn(Schedulers.computation())
.map(Observables05::doSomething)
.subscribe(System.out::println, Throwable::printStackTrace, () ->...
779 просмотров
schedule
13.10.2022
Как организовать цепочку асинхронных вызовов в стиле RxJava2
У меня есть следующий код, завернутый в класс AsyncTask
AsyncTask<Void, Void, Void> task = new AsyncTask<Void, Void, Void>() {
@Override
protected Void doInBackground(Void... params) {
try {...
1235 просмотров
schedule
05.10.2022
Перехватывать только исключения определенного типа в RxJava 2
Я только изучаю RxJava 2, и я хотел бы перехватывать исключения только определенного типа и возвращать Observable. По сути, я хочу, чтобы onErrorResumeNext() перехватывала только определенный класс исключений, но похоже, что она так не работает....
5589 просмотров
schedule
10.09.2022
Несколько запросов на модификацию2 объединены в хэш-карту с rxJava2
У меня есть список объектов: ArrayList<T> arrayList; и на каждом объекте списка есть Id: T.getId() который мне нужен для выполнения запроса. В ответ выбирается другой список объектов: ArrayList<E> anotherList
Я хочу сделать...
280 просмотров
schedule
05.03.2023
Функция защиты от ошибок RxJava2 не работает должным образом в RecyclerView - Android
Я пытаюсь создать Custom ImageButton, который будет накапливать клики и запускать событие, когда пользователь перестает нажимать кнопку в течение 1 секунды.
Для этого я использовал функцию debounce.
Пользовательский ImageButton:
public class...
1142 просмотров
schedule
24.04.2023
Объединение вызовов модификации с помощью Rxjava
У меня есть список [Список чатов], содержащий все чаты, хранящиеся на моем телефоне. Я отправляю этот список на сервер, который в ответ отправляет мне список всех чатов, которых у меня нет [Отсутствующие чаты]. Для каждого элемента в списке...
252 просмотров
schedule
09.07.2023
2 зависимых запроса на модификацию, сделанные RxJava
Я использую Foursquare API для получения фотографий близлежащих мест и отображения их. Я делаю это с помощью RxJava и Retrofit. В первый раз мне нужно запросить список мест с правильными идентификаторами, а второй запрос должен быть с...
599 просмотров
schedule
21.03.2023
В чем разница между RxJava 2 Cancelable и Disposable?
Я хочу создать прослушиватель кликов Observable из представления, используя RxJava 2. Я начал с самой простой реализации (здесь я не использую лямбда-выражения, чтобы показать вам разные типы в этом методе):
Observable<View>...
8612 просмотров
schedule
25.12.2022
RxJava и долгоиграющий слушатель
Итак, я новичок в RxJava2 (ну, я тоже не знаю RxJava) и пытаюсь разработать приложение для Android, используя структуру RxJava2 и MVP.
В этом приложении я делаю асинхронные вызовы к библиотеке, которая использует прослушиватели. Я устанавливаю...
299 просмотров
schedule
24.09.2022
RxJava: наблюдаемый поток и поток по умолчанию
У меня такой код:
Observable.create(new ObservableOnSubscribe<String>() {
@Override
public void subscribe(@NonNull final ObservableEmitter<String> s) throws Exception {
Thread thread = new...
7848 просмотров
schedule
05.01.2023
rxjava .zip onNext() не выполняется
я объединил несколько наблюдателей в zip для выполнения нескольких запросов с сервера, но onNext не выполняется, поэтому я не могу получить возвращаемые значения. menuName, restaurantName и userName являются глобальными переменными.
public void...
429 просмотров
schedule
31.10.2022
Ошибка компиляции RxJava в следующем случае
Я хотел бы попробовать очень простой код RxJava, например следующий
int[] test = {1,2,3,4};
Observable<Integer> findAverage = Observable.fromArray(test);
averageInteger(findAverage).subscribe(System.out::println);
Сначала я встретил...
134 просмотров
schedule
31.10.2022
Как заставить общий наблюдаемый объект выдавать новое значение из .startWith() каждый раз, когда общий поток получает нового подписчика?
Мне нужна общая наблюдаемая, чтобы выдавать новое значение .startWith() каждый раз, когда подписывается общий поток (счетчик подписчиков идет от 0 до 1). К сожалению, значение, возвращаемое .startWith() , повторно используется в течение всего...
442 просмотров
schedule
20.02.2023
