Вопросы по теме 'rx-java2'
В чем разница между «Может быть» и «Необязательно» в rxjava2?
Док говорит
Концептуально это объединение Single и Completable, обеспечивающее средства для захвата шаблона эмиссии, где может быть 0 или 1 элемент или ошибка, сигнализируемая некоторым реактивным источником.
Но я не уверен, что это на...
14115 просмотров
schedule
30.12.2023
Не удается разрешить метод «подписаться (анонимный io.reactivex.functionx.Consumer‹java.util.List‹››)» в rxjava2?
после выполнения оператора toList исходный Flowable‹‹\List>> преобразуется в Single‹‹\List>>. и получается, если я создам Consumer для подписки на Single, тип значения Consumer не может быть изменен, кроме как Object?
@Override
public void...
3460 просмотров
schedule
07.03.2023
RxJava 2.0 - Как преобразовать Observable в Publisher
Как преобразовать Observable в Publisher в RxJava версии 2?
В первой версии у нас есть проект https://github.com/ReactiveX/RxJavaReactiveStreams , который делает именно то, что Я нуждаюсь. Но как мне это сделать в RxJava 2?
12866 просмотров
schedule
11.04.2023
Метод обратного вызова часто вызывается для пересылки события в Observable?
Итак, у меня есть этот слушатель в виде настраиваемого слайдера. Представление вызывает onSliderChanged(int percent) , когда пользователь перемещает ползунок. Я пытаюсь сделать сетевой вызов при смене ползунка, но я не хочу делать миллион сетевых...
488 просмотров
schedule
09.12.2022
Оптимизированный кэш и сетевой метод takeUntil с помощью Retrofit, RxJava и Gson
Я пытаюсь реализовать оптимизированный кеш и сетевой метод, используя оператор RxJava takeUntil для получения данных с сервера. Я использую модель Gson для анализа ответов JSON от API.
Я застреваю при получении данных с сервера из-за...
361 просмотров
schedule
28.03.2023
Элемент доступа RxJava ниже по течению
Я связал вместе несколько операторов rx для выполнения нескольких задач. Мне нужно получить доступ к полю из объекта, который находится в родительском потоке, нижестоящем.
т.е. Как я могу получить доступ к channel.uid вниз по течению?...
273 просмотров
schedule
06.04.2023
RxJava: отписка OnNext не работает
Я пытаюсь отказаться от подписки после получения первого элемента из наблюдаемого. И, кажется, не работает. Что я делаю не так?
public class ObservableAndSubscriber {
public static void main(final String[] args) {
final...
629 просмотров
schedule
30.07.2022
Обработка пустого ответа с помощью модификации и rxjava 2.x
При использовании rxjava 1.x я возвращал Observable<Void> для обработки пустого ответа от модификации:
@POST( "login" )
Observable<Void> getToken( @Header( "Authorization" ) String authorization,...
9574 просмотров
schedule
01.06.2022
Не удается разрешить метод Observable.from в rxjava 2
В классе Observable в rxjava 1 есть метод from, но его нет в rxjava 2. Как я могу заменить метод from в rxjava 2 в следующем коде:
List<Integer> ints = new ArrayList<>();
for (int i=1; i<10; i++) {
ints.add(new...
8270 просмотров
schedule
28.11.2022
RxJava Subject с противодавлением — пусть весь список будет испускаться после того, как нисходящий поток закончит потребление
у меня такой же вопрос, как этот Тема RxJava с противодавлением - позволять последнему значению выдавать только после того, как нисходящий поток закончил потребление , но вместо этого мне нужны все элементы, которые были выделены (список всех...
1702 просмотров
schedule
06.07.2022
Отправлять накопленные запросы в веб-сервис - RxJava2
У меня есть кнопка добавления в моем приложении, чтобы позволить пользователю добавлять элемент в список, если пользователь нажимает кнопку добавления, я не получаю запрос на немедленный переход к веб-сервису, я хочу, чтобы запрос накапливался и...
141 просмотров
schedule
04.06.2022
Преимущества / недостатки реактивного программирования
Я продолжаю изучать и пробовать реактивный стиль кодирования с использованием Reactor и RxJava. Я понимаю, что реактивное кодирование лучше использует процессор по сравнению с однопоточным исполнением.
Есть ли какое-либо конкретное сравнение между...
24047 просмотров
schedule
06.01.2023
Исключение не распространяется на onError() при вызове из doOnSubscribe()
Существует PublishProcessor , который вызывает оператора .doOnSubscribe(checkCondition) для выполнения определенной проверки. checkCondition предназначен для выбрасывания UnsupportedOperationException , который затем должен быть передан...
398 просмотров
schedule
24.09.2022
RxJava 2, Retrofit 2 + Retrolambda - объединение 2 запросов в цепочку
Первый вызов API возвращает список элементов, а затем я хочу впоследствии вызвать другой API с String , возвращенным в каждом элементе списка из первого вызова API. Я (думаю, у меня) получил это так, что он вызывает второй вызов API с каждым...
1562 просмотров
schedule
27.07.2023
RXJava 2 / RxAndroid 2 vs Observable vs Listener для наблюдения из разных классов
так как я хотел бы начать свое новое приложение с чистой базой, я ищу хороший способ обмена информацией между разными классами. В качестве примера я хотел бы подписаться на интерфейс, который может использоваться / совместно использоваться разными...
2278 просмотров
schedule
22.02.2023
Как кэшировать реактивного издателя, такого как Observable?
Я пытаюсь понять, что произойдет, если я кеширую результат метода, возвращающего холодный Observable? Поток еще не материализовался, так что же на самом деле содержит кеш? Я пытался выяснить это с помощью Hazelcast и Spring Boot, но не смог...
1357 просмотров
schedule
15.07.2023
RxJava Проблемы с тестированием Presenter в Android
Привет, я хочу протестировать ведущего Android с помощью mockito, и у меня много проблем. Вот код, который я хочу протестировать:
public class SignUpPresenter extends BasePresenter {
private static final String TAG =...
585 просмотров
schedule
30.05.2023
Как собрать выбросы двух наблюдаемых в разные списки? используя RxJava?
У меня есть две наблюдаемые, каждая из которых вернет список объектов. Я хотел бы собрать этот список, а затем использовать DiffUtil функция Android для удаления несуществующих элементов из первого списка. У кого-нибудь есть идеи для этого, кроме...
410 просмотров
schedule
09.11.2022
RxJava2 создает Flowable из слушателя и удаляет слушателя в конце
Мой вариант использования связан с использованием RxJava2 с базой данных Firebase.
У меня есть DatabaseReference , и я могу зарегистрироваться дорожить слушателями. Я могу преобразовать его в поток следующим образом:
disposable =...
1992 просмотров
schedule
12.03.2024
Rxjava2 просмотр кликов в адаптере ресайклера
Я использую версию моментального снимка rxbindings, совместимую с rxjava2, и все работает отлично, но я не знаю, как обрабатывать события кликов внутри адаптера recyclerView. Я пытался использовать «rxjava 1 way», но это не сработало.
RxJava 1.0:...
1605 просмотров
schedule
30.12.2022
