12
ответов
RxJava-тестирование NullPointerException в Schedulers.io () [duplicate]
У меня есть единичный тест для тестирования пользовательского репозитория, и я использую настраиваемое правило для переопределения планировщиков, и я все равно получаю исключение NullPointerException. Открытый тестовый код UserRepositoryTest расширяет ...
вопрос задан: 26 May 2016 16:15
12
ответов
java.lang.NullPointerException: плагин возвращает null Observer [дубликат]
Я искал NullPointerException: плагин вернул null Observer, но не нашел полезного исправления. Я нашел эту проблему в Crashlytics, поэтому у меня нет сценария для ее создания. Полная ошибка ...
вопрос задан: 26 May 2016 16:15
7
ответов
rxjava: мгновенный поиск Android [дубликат]
Я пытаюсь реализовать мгновенный поиск с помощью rxjava. Ниже приведен код, который я написал: getCompositeDisposable (). Add (RxTextView.afterTextChangeEvents (appCompatEditText) .debounce (...
вопрос задан: 22 October 2008 11:41
6
ответов
android 4.X: NoClassDefFoundError: io / reactivex / Наблюдаемый [дубликат]
Я использую базу данных aws dynamodb с приложением android. Приложение работает идеально с более высокой версией Android. SDK версия dynamodb - com.amazonaws: aws-android-sdk-ddb-mapper: 2.6.15 ...
вопрос задан: 28 September 2015 07:18
3
ответа
AndroidSchedulers.mainThread наблюдает onError раньше, чем onNext [duplicate]
Сегодня я застрял, поскольку у меня были проблемы с AndroidSchedulers.mainThread () Observable.create (emitter - & gt; {emitter.onNext (1); emitter.onNext (2); emitter.onNext (3); // Thread.sleep (10), ...
вопрос задан: 21 August 2015 16:09
3
ответа
RxJava Как заставить наблюдателей обрабатывать в порядке [дублировать]
У меня есть прецедент, когда мне нужно подписать наблюдателей A и B к наблюдаемому, но я хочу, чтобы A выполнялось до B. Я понимаю, что в зависимости от порядка подписки не рекомендуется, поэтому я был ...
вопрос задан: 8 May 2014 07:26
2
ответа
Как отправить пользовательский бросок через flatmap в RxJava на Android?
Поэтому я использую flatMap с RxJava для объединения некоторых вызовов API, которые возвращают Singles, и мне было интересно, как передать пользовательский метод throwable методу подписки в метод flatmap, в зависимости от моего собственного ...
вопрос задан: 18 January 2019 18:51
2
ответа
Одна наблюдаемая должна излучать предметы на основе других наблюдаемых излучаемых предметов, и обе наблюдаемые не связаны
У меня есть два разных Observable, которые ведут себя как поведение Observable one -> Это будет создано, и один DisposableObserver будет подписан на него и реагирует на элементы, испускаемые Observable ...
вопрос задан: 16 January 2019 23:55
1
ответ
RxJava 2.0 - как создать Observable из Completables
Допустим, у меня есть что-то вроде Completable doTask (); Я хочу реализовать поток, который испускает элемент только («Completed») после завершения doTask () Для Observable я могу сделать doTask (). Map (f -> ...
вопрос задан: 20 March 2019 06:29
1
ответ
Как сравнить элементы в двух наблюдаемых, а затем фильтровать на основе совпадений в RxJava2?
Как сравнить элементы в двух наблюдаемых, а затем фильтровать на основе совпадений в RxJava2? Я пытаюсь сравнить две наблюдаемые. Оба состоят из объектов Server с идентификатором и адресом сервера. ...
вопрос задан: 18 March 2019 18:49
1
ответ
Список & л ;? Расширяет что-то > создается вместо списка < Something >
У меня есть вызов службы, который возвращает ответ JSON, который затем передается через менеджер данных, который преобразует данные, если служба работает успешно, или создает тело ошибки, если вызов является ошибкой. ...
вопрос задан: 3 March 2019 17:01
1
ответ
rxjava завершено после повторной попытки при завершении
Я использую оператор retryWhen на Completeable, есть ли способ сказать, что это завершено от повторной попытки Flowable? что-то вроде этого - PublishSubject <? > retrySubject = PublishSubject.create () ...
вопрос задан: 25 February 2019 08:52
1
ответ
Получение элементов в onNext () после вызова dispose () в RxJava
Вот что я прочитал о dispose () здесь: в двух словах, когда Disposable (который реализуется TestObserver) удаляется, Observer (также TestObserver) больше не будет получать ...
вопрос задан: 25 February 2019 00:16
1
ответ
Лучший способ получить список из Observable в Rxjava
Я просто изучаю Rxjava в одном из своих приложений для Android и застрял в одном месте, честно говоря, я очень новичок в этой библиотеке, так что не против, если мой вопрос кого-то расстроит ;-) Так что я пытаюсь .. ,
вопрос задан: 22 February 2019 07:50
1
ответ
RxJava 2: множественные наблюдатели не получают от одного наблюдаемого
Я создаю наблюдаемую, на которую подписываются несколько наблюдателей. Но я вижу, что только один из наблюдателей на следующем звонке. Что я здесь не так делаю. частная наблюдаемая < String > ...
вопрос задан: 19 January 2019 02:43
1
ответ
Клиент Vertx Mongo подавляющим Mongodb с одновременными обновлениями
Попытка построить реактивную систему с использованием akka, rx, vert.x и mongodb, где поток (нисходящий поток) выглядит в значительной степени: потоки акки - > rx streams - > Шина событий vert.x - > ...
вопрос задан: 19 January 2019 02:40
1
ответ
Ожидание завершения двух наблюдаемых, прежде чем продолжить?
У меня есть страница загрузки, где я хочу выполнить два сетевых запроса (retrofit2-rxjava) для получения несвязанной информации. Я не хочу переходить на следующую страницу, пока эти два запроса не будут закончены, даже ...
вопрос задан: 18 January 2019 21:41
1
ответ
Начиная асинхронную операцию с использованием RxJava без подписки на наблюдаемое?
Допустим, у вашего DAO есть такой метод, который обновляет записи пользователей в БД: Недавно я начал изучать RxJava и до сих пор видел много примеров, как ...
вопрос задан: 18 January 2019 07:33
1
ответ
Миграция HystrixCommands в Resilience4j
Учитывая, что Hystrix переходит в режим обслуживания, я работаю над переносом (довольно большой) кодовой базы в Resilience4j. Я интенсивно использую следующий шаблон с Hystrix: новый HystrixCommand < ...
вопрос задан: 17 January 2019 15:16
1
ответ
Как я могу связать пользовательское задание и другой класс в rxJava2?
Я создаю задачу в классе (A) и вызываю асинхронно, затем, если задача завершена или отменена, передайте результат другому классу (B) с использованием в rxJava2. Я очень новичок в rxJava2 и я запутался.
вопрос задан: 17 January 2019 07:41
1
ответ
Правильный способ утилизации Rx Disposable в презентере при смене ориентации
Проблема: когда я пытаюсь повернуть телефон сразу после PullToRefresh, мой Observable не завершит свою работу из-за метода dispose (), который я вызывал в onPause. Я понимаю, почему это происходит ...
вопрос задан: 15 January 2019 18:19
1
ответ
Почему Spring Boot имеет две разные реализации ReactiveX?
Spring Boot имеет две разные зависимости, каждая из которых реализует один и тот же API: Project Reactor и RxJava 2. Вы можете проверить зависимости при весенней загрузке здесь. Так почему дублирование? Есть ли ...
вопрос задан: 15 January 2019 17:01
1
ответ
Как цепочка Наблюдаемые динамически с помощью итерабельного / списка?
В настоящее время я использую RxJava, и у меня есть что-то вроде этого: List & lt; Integer & gt; taskIds = ... Observable.just (новая задача (taskIds.get (0))) .compose (executeWorkFlow ()) .filter (Response :: ...
вопрос задан: 13 July 2018 20:46
1
ответ
Поведение ConnectableObservable в RxJava2?
Я использую Observable myObs, который испускает один и только один элемент и никогда не завершается. Я хочу разделить этот элемент на несколько подписчиков в разное время. .replay (1) преобразует источник в ...
вопрос задан: 13 July 2018 20:29
1
ответ
Rx Kotlin / Java, наблюдаемый по состоянию
Есть ли способ создать RxJava2 Observable для уведомления об изменениях состояния? например: private var internalState = "state1" val state: Observable & lt; String & gt; = Наблюдаемое (...) ... fun updateState (newState: ...
вопрос задан: 13 July 2018 18:13
1
ответ
Как отложить подписку на RxJava как с успехом, так и с ошибкой?
Я хотел бы отложить подписку на отправку по времени XXXX независимо от ошибки или успеха. В следующем коде задержка работает только для сценария успеха. Пожалуйста, помогите мне, чтобы он ...
вопрос задан: 13 July 2018 13:37
1
ответ
RxJava2, Как совместить результат нескольких наблюдаемых?
Я разрабатываю приложение для Android. У меня вопрос о RxJava2. Вот пример: у меня есть список идентификаторов пользователя. (1, 2, 3, 4, 5, ...) val userIds = listOf (1, 2, 3, 4, 5) Я хочу составить список пользователей ...
вопрос задан: 13 July 2018 08:09
1
ответ
Split Observable & lt; List & lt; Foo & gt; & gt; в отдельные предметы [дубликат]
Я вызываю API с помощью Retrofit, используя следующий метод @GET («конечная точка») Observable & lt; List & lt; Foo & gt; & gt; getLatestFoo (); Когда я хочу называть эту конечную точку, я подписываюсь на нее, используя ...
вопрос задан: 16 April 2015 12:26
0
ответов
Как сбросить BehaviorSubject
У меня есть BehaviorSubject, который я хотел бы сбросить - я имею в виду, что хочу, чтобы последнее значение не было доступно, как если бы оно было только что создано. Я не вижу API для этого, но я полагаю ...
вопрос задан: 17 July 2019 13:16
0
ответов
RxJava2 concatMap и concatMapEager от Flowable с наблюдать за имеют различное поведение
Должны ли pubisher.observerOn (планировщик) .concatMap (mapper, 1) и publisher.observerOn (планировщик) .concatMapEager (mapper, 1, 1) работать одинаково, когда concatMapEager использует параллелизм с 1? Я тестирую ...
вопрос задан: 14 April 2019 07:26