Описание тега rx-java2

Описание тега Вопросы с тегом
None Все , что связано с RxJava2 - новая реализация реактивных расширений RxJava для JVM - библиотеки для создания асинхронных и основанных на событиях программ с использованием наблюдаемых последовательностей для виртуальной машины Java.
1 ответ

Противодавление в RxJava2

Предполагается, что у меня есть 1 миллион строк записей в базе данных. Затем я использую Flowable (вместо Observable) для чтения записей, затем записываю их в файл с медленным шифрованием (запись намного медленнее, чем чтение). Если я не использую "…
05 сен '17 в 11:07
1 ответ

Ошибка компиляции RxJava2 "не удается найти метод символа body()"

Я получил ошибку компиляции в этой части кода mCompositeDisposable.add( Flowable.just(Boolean.TRUE) .flatMap( ignored -> service.getPosts(offset,limit, PreferencesUtils.getAccessTokenKey()) ) .subscribeOn(Schedulers.io()) .doOnNext(response ->…
09 май '18 в 15:52
1 ответ

RxJava 2: Retry Completable при отправке уведомлений о повторных попытках подписчикам

Я новичок в RxJava 2 и хочу повторить Completable вызов сервера API до успешного завершения при отправке уведомлений о попытках повторных попыток, чтобы мой пользовательский интерфейс мог отображать состояние повторных попыток для пользователя. Что-…
24 фев '17 в 17:59
1 ответ

Как предварительно выполнить операцию, которая возвращает по одному для каждого элемента списка, возвращаемого наблюдаемой, и возвращать его в виде списка?

Вопрос довольно сложный, но в коде, кажется, выглядит проще (я надеюсь) У меня есть такие функции, как ниже fun trackFoos(): Observable<List<Foo>> {/*....*/} fun getBarForFoo(fooState: Foo.State): Single<Bar> И у меня был какой-то …
05 окт '18 в 10:42
1 ответ

Как отфильтровать список и собрать его индекс для строкового результата, используя RxJava2?

Это мой код для сбора индекса флажка, который проверил и получить строковый результат. StringBuilder sb = new StringBuilder(); for (int i = 0; i < checkBoxList.size(); i++) { if (checkBoxList.get(i).isChecked()) { sb.append((i + 1) % 7 + 1); sb.a…
15 май '17 в 12:52
1 ответ

RxJava2: выполнить асинхронную функцию для каждого элемента в списке и ожидать обратного вызова

Я борюсь с RxJava2. Я хочу выполнить функцию для каждого элемента списка. Эта функция: public void function(final Result result) { FirebaseFirestore.getInstance().collection(COLLECTION_NAME).document(result.getId()).get().addOnSuccessListener(new On…
28 июл '18 в 13:51
2 ответа

Понимание метода RxJava с кодом не в потоке

У меня есть функция, которая выглядит так: public Flowable<Integer> max(int a, int b){ // *** Part 1 - start *** int max = Math.max(a,b); // *** Part 1 - end *** return Flowable.defer(() -> { // *** Part 2 start *** return Flowable.just(max…
06 фев '18 в 12:53
2 ответа

Звоните в сеть api, так как активность заканчивается

У меня есть экран настроек в моем приложении, и я хочу сохранить пользовательские настройки на сервере, но я не хочу, чтобы в настройках была какая-либо кнопка обновления, я надеялся сделать этот вызов api обновления, когда действие заканчивается, м…
16 окт '18 в 07:20
8 ответов

Тест Android RxJava 2 JUnit - getMainLooper в android.os.Looper не высмеивается RuntimeException

Я сталкиваюсь с RuntimeException при попытке запустить тесты JUnit для докладчика, который использует observeOn(AndroidSchedulers.mainThread()), Поскольку они являются чистыми тестами JUnit, а не инструментальными тестами Android, у них нет доступа …
11 апр '17 в 21:14
1 ответ

Плоская карта RxJava: что происходит, когда завершается одно из наблюдаемых результатов?

Я новичок в RxJava, я знаю, что плоские карты предназначены для отображения испускаемого элемента на наблюдаемый. Я также знаю, что на основании документации все излучаемые наблюдаемые объединяются (сглаживаются) в один наблюдаемый поток. Мне было и…
16 апр '17 в 04:36
1 ответ

Зацикливание rxLocationManager

Я создал LocationManager для обработки проблем с разрешениями и возврата lastLocation из FusedLocationProviderClient. Он интенсивно использует RxJava, чтобы избежать ада обратного вызова. Вот код: object LocationManager { // using coarse location to…
09 фев '18 в 14:49
1 ответ

Как получить разницу между двумя наблюдаемыми?

У меня есть obs1 = Observable.range(1, 10) а потом obs2 = Observable.range(5, 10) (как правило, последовательность не будет в порядке возрастания). Я хочу получить разницу между obs2 и obs1, чтобы получить значения (наблюдаемые из них) от obs2, кото…
11 янв '18 в 11:20
1 ответ

Как использовать void Subject в RxJava2?

Мне удалось создать это так: private final PublishSubject<Void> subject = PublishSubject.create(); Но как передать ему значение в onNext(T t)? Я не могу передать ему значение null, потому что он выдаст исключение. onComplete тоже не вариант.
30 авг '17 в 09:32
1 ответ

RxJava2 Flowable.combine Последнее поведение, если все Flowables не излучают

Я следую этому коду, чтобы сделать некоторые проверки ошибок. Ниже приведена реализация CombineLatest, которая принимает входные данные из 3 полей и выполняет проверку ошибок для каждого из них. Flowable.combineLatest( _emailChangeObservable, _passw…
05 июл '17 в 19:14
1 ответ

Повторите, когда альтернатива, если наблюдаемая не завершена?

Я хотел бы вручную повторить наблюдаемое с последним выданным значением. Я знаю операторов повтора и повтора, однако эти афаики работают только для ошибочных и завершенных наблюдаемых. Моя наблюдаемая никогда не заканчивается, так что это не работае…
29 янв '18 в 18:57
1 ответ

Как использовать RxJava для последовательной работы нескольких потоков

Предположим, что есть 3 потока, T1, T2, T3. Как я могу заставить их работать последовательно, скажем, порядок выполнения - T1, T2, T3, T1, T2, T3... Можем ли мы использовать RxJava для его реализации? Возможно ли, что есть 3 нити и отдельно распечат…
08 июн '18 в 03:10
3 ответа

NPE пока список фильтров с io.reactivex.Observable

Я столкнулся с проблемой, пока пытаюсь отфильтровать ArrayList из String как Observable, Все работает нормально, если: MatrixCursor suggestionsCursor = new MatrixCursor(new String[]{BaseColumns._ID, COLUMN_FIELD_NO}); for (int i = 0; i < data.siz…
10 авг '18 в 09:41
0 ответов

RxJava2 setCancellable против doFinally

Является ли действие в setCancellable называется при всех тех же обстоятельствах, что и doFinally? В следующем примере я могу просто использовать setCancellableили делает doFinally покрыть больше случаев? var closeable: Closeable? = null Flowable.de…
05 ноя '18 в 20:31
1 ответ

RxBinding с RadioGroup и CheckBoxes

Я реализовал rxjava в своем проекте с помощью butterknife следующим образом: @BindView(R.id.login_et) EditText mLoginField; @BindView(R.id.password_et) EditText mPassField; @BindView(R.id.login_bt) Button mLoginButton; @BindDrawable(R.drawable.error…
14 дек '17 в 08:51
1 ответ

Подписчик onNext вызывается до завершения асинхронных запросов в rxjava2.

Я реализовал шаблон хранилища в MVP, используя RxJava2 RemoteDataSource.java public Observable<List<A>> getAList(){ return ApiService. getAList() .compose(RxUtils.applySchedulers()) .doOnSubscribe(disposable -> Timber.d(..)) .doOnErro…
07 сен '18 в 15:54