Вопросы по теме 'rx-java'
RxJava и случайные спорадические события на Android
Я хочу использовать RxJava так же, как использовал бы EventBus или Otto в Guava, но я не понимаю, как заставить его работать так, путь.
Вот сценарий: допустим, я хочу иметь кнопку в своем приложении для Android, и каждый раз, когда кнопка...
1867 просмотров
schedule
01.05.2024
После отмены подписки моя подписка продолжает действовать
Я пытаюсь изучить RxScala. Я использую Observable.interval(1 second).buffer(10 seconds) и делаю подписку для печати значений, но не могу правильно отказаться от подписки. После того, как я отменил подписку, она продолжает работать, но с пустым...
403 просмотров
schedule
10.08.2023
RX: Запускать Zipped Observables параллельно?
Итак, я играю с RX (действительно круто), и я преобразовываю свой API, который обращается к базе данных sqlite в Android, чтобы возвращать наблюдаемые.
Поэтому, естественно, одна из проблем, которую я начал пытаться решить, звучит так: «Что, если я...
10590 просмотров
schedule
25.02.2024
RxJava (или Rx.NET), эквивалент RACObserve от ReactiveCocoa
Учитывая произвольное поле в объекте Java, я хочу создать Observable, который будет следить за этим полем и отправлять новый результат в Observer каждый раз, когда значение поля изменяется. В ReactiveCocoa есть макрос RACObserve, который, похоже,...
880 просмотров
schedule
04.11.2023
Как определить завершение всех содержащихся Observables в Observable‹Observable‹Object››
Я хочу, чтобы метод в моем API возвращал Observable‹Observable‹Object››, но я хочу, чтобы код в этом методе знал, как только все содержащиеся Observables будут завершены, чтобы он мог что-то закрыть. Как лучше всего это сделать?
Чтобы быть более...
960 просмотров
schedule
27.02.2023
Лучшая практика обработки onError и продолжения обработки
Я новичок в RxJava, но я интегрирую его в проект, над которым работаю, чтобы помочь мне его изучить. Я столкнулся с вопросом о лучших практиках.
У меня есть вопрос о том, как обработать onError , чтобы предотвратить остановку обработки...
27070 просмотров
schedule
24.06.2022
RxJava - цикл через асинхронные задачи и ожидание завершения
Я пытаюсь выполнить некоторую асинхронную работу с n элементами и дождаться завершения всех элементов, прежде чем продолжить.
Что я должен указать в whatfunc? местоположении, чтобы подписка onComplete срабатывала один раз?...
1366 просмотров
schedule
28.10.2023
Последовательность реализации: List‹Observable‹T›› -› Observable‹List‹T››
Для каждого типа T, имеющего список n Observables of Ts, я хотел бы построить Observable, испускающий список n Ts каждый раз, когда один из исходных Observables что-то испускает. В функциональной литературе его часто называют оператором...
96 просмотров
schedule
07.02.2024
Использование Observable в пользовательском подклассе приложения
Допустимо ли создавать Rx Observables в пользовательском подклассе приложения. Причина этого в том, что я могу создать BehaviorSubject внутри приложения и каждые 10 минут запрашивать изменения с сервера, каждое действие или фрагмент, который...
859 просмотров
schedule
14.09.2022
Регистрация нескольких подпрограмм завершения
У меня есть Observable , который построен из Stream[Item] ( Item здесь просто для примера). Этот наблюдаемый проходит через набор преобразований:
val observable: Observable[Item] = ... //construct observable from stream
val observable1:...
67 просмотров
schedule
13.11.2023
В чем разница между concatMap и flatMap в RxJava
Кажется, что эти две функции очень похожи. У них одинаковая подпись (принимает rx.functions.Func1<? super T, ? extends Observable<? extends R>> func ), и их мраморные диаграммы выглядят точно так же. Не могу вставить сюда картинки, но...
26537 просмотров
schedule
02.06.2022
Преобразование наблюдаемого в список
Я использую RxJava.
У меня есть Observable<T> . Как преобразовать его в List<T> ?
Вроде простая операция, но нигде в сети не нашел.
39050 просмотров
schedule
01.06.2024
onNext запустить еще один Observable
Есть ли более чистый способ сделать следующее?
У меня есть Android-наблюдатель, который отклоняет запросы. onNext вызывает вторую наблюдаемую.
{// when creating the android activity
searchTextEmitterSubject = PublishSubject.create();...
1869 просмотров
schedule
26.07.2022
Испускать элементы в RxJava с интервалом, который зависит от самого испускаемого элемента
В RxJava для Android я хочу генерировать элементы с интервалом, который зависит от самого элемента: в Observable я извлекаю элемент из очереди, обрабатываю его и отправляю. В зависимости от типа элемента, я хочу настроить, через какое время будет...
1425 просмотров
schedule
10.12.2022
rxjava — Как обрабатывать исключения слияния, не прерывая весь процесс
Я создал два наблюдаемых объекта. Один из них выдает исключение.
obs1 = Observable.from(new Integer[]{1, 2, 3, 4, 5, 6});
obs2 = Observable.create(new Observable.OnSubscribe<Integer>() {
@Override public void call(Subscriber<? super...
1254 просмотров
schedule
14.09.2023
RxJava: почему одни и те же преобразования пересчитываются для каждой ветки наблюдаемых?
Введение
Рассмотрим простой фрагмент кода Java. Он определяет две наблюдаемые a и b в терминах c , который сам определяется с помощью d (a, b, c, d имеют тип Observable<Integer> ) :
d = Observable.range(1, 10);
c =...
588 просмотров
schedule
30.03.2024
Обработка списка задач с интенсивным вводом-выводом параллельно с RxJava
Мне нужно получить несколько файлов параллельно. Сама операция get требует большого количества операций ввода-вывода и может значительно выиграть от параллельного выполнения.
С RxJava я смог добиться этого, заключив свою функцию в Async.toAsync ....
3094 просмотров
schedule
01.08.2023
В чем разница между наблюдателем и подписчиком?
Я пытаюсь расшифровать следующую функцию:
Subscription getCar(id, Observer<Car> observer) {
return getCarDetails(id, new Observer<CarDetails> {
@Override
onNext(CarDetails...
34659 просмотров
schedule
28.07.2023
RxJava: retryWhen с ограничением повторных попыток
Я новичок в ReactiveX и реактивном программировании в целом. Мне нужно реализовать механизм повторных попыток для операций Couchbase CAS, но пример на веб-сайте Couchbase показывает retryWhen, который, кажется, повторяется бесконечно. Мне нужно...
7943 просмотров
schedule
22.03.2024
Как выводить элементы из списка с задержкой в RxJava?
Я использую Retrofit для получения закладок из REST API:
public interface BookmarkService {
@GET("/bookmarks")
Observable<List<Bookmark>> bookmarks();
}
Теперь я хотел бы выпустить каждый элемент из этого списка с...
5359 просмотров
schedule
15.09.2023
