4
ответа

Как мне обработать исключения в map () в Observable в RxJava

Я хочу сделать это: Observable.just (bitmap) .map (new Func1 < Bitmap, File > () {@Override public File call (Bitmap photoBitmap) {// ...
вопрос задан: 30 April 2017 06:27
3
ответа

В чем разница между операторами () и just () в RxAndroid для загрузки списка массивов? [Дубликат]

Я пытаюсь с помощью и просто оператор, использующий rxandroid.I обнаружил, что из испускает только одно значение из списка значений. Но только с помощью мы можем сделать наблюдателя onNext значением как List of string.Is то же самое ...
вопрос задан: 13 June 2015 14:14
3
ответа

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

У меня есть прецедент, когда мне нужно подписать наблюдателей A и B к наблюдаемому, но я хочу, чтобы A выполнялось до B. Я понимаю, что в зависимости от порядка подписки не рекомендуется, поэтому я был ...
вопрос задан: 8 May 2014 07:26
2
ответа

Одна наблюдаемая должна излучать предметы на основе других наблюдаемых излучаемых предметов, и обе наблюдаемые не связаны

У меня есть два разных Observable, которые ведут себя как поведение Observable one -> Это будет создано, и один DisposableObserver будет подписан на него и реагирует на элементы, испускаемые Observable ...
вопрос задан: 16 January 2019 23:55
1
ответ

В чем разница между concatMap и flatMap в RxJava

Кажется, что эти 2 функции очень похожи. Они имеют одинаковую подпись (принимая rx.functions.Func1 > func) и их мраморные диаграммы ...
вопрос задан: 11 July 2019 10:52
1
ответ

RxJava 2.0 - как создать Observable из Completables

Допустим, у меня есть что-то вроде Completable doTask (); Я хочу реализовать поток, который испускает элемент только («Completed») после завершения doTask () Для Observable я могу сделать doTask (). Map (f -> ...
вопрос задан: 20 March 2019 06:29
1
ответ

Кто сделал RxJS / ReactiveX?

Мне интересно, кто запустил ReactiveX / RxJS? Rx, кажется, реализован на многих языках / платформах, мне интересно, каково его происхождение? Какой проект был первым? RxJS интенсивно используется в ...
вопрос задан: 10 March 2019 17:05
1
ответ

Что делает .defer () в RxJava?

Я новичок в RX Java, и я не могу понять, что приносит Completable.defer и почему это хорошая практика, чтобы использовать его. Так в чем же разница: public Completable someMethod1 () {return ...
вопрос задан: 6 March 2019 08:00
1
ответ

RX-Android + ViewModel + Retrofit не вызывает OnComplete ()

Я не могу получить метод OnComplete () для вызова после обработки всех элементов. Мне нужно сделать это для того, чтобы (как минимум, скрыть представление загрузки). Я немного новичок в JavaRX, поэтому я не знаю, где ...
вопрос задан: 2 March 2019 23:17
1
ответ

Правильная операция приема для слияния двух наблюдаемых

Я написал ниже класс для доступа к своему репо, который включает в себя как удаленное, так и локальное репо. открытый класс VenuesRepoImpl реализует VenuesRepo {private VenuesLocalRepo venuesLocalRepo; частный ...
вопрос задан: 25 February 2019 15:08
1
ответ

Буферизация RxJava - игнорирование нулевых элементов

Вот код, который у меня есть для буферизации и преобразования входящих событий: public Publisher < Collection < EventTO > > logs (String eventId) {ConnectableObservable < Event > ...
вопрос задан: 20 January 2019 04:24
1
ответ

Клиент Vertx Mongo подавляющим Mongodb с одновременными обновлениями

Попытка построить реактивную систему с использованием akka, rx, vert.x и mongodb, где поток (нисходящий поток) выглядит в значительной степени: потоки акки - > rx streams - > Шина событий vert.x - > ...
вопрос задан: 19 January 2019 02:40
1
ответ

Интегрировать API библиотеки Google Photos в приложение для Android

Я хочу интегрировать API фотографий Google в Android, я выполнил вход в Google, но не могу получить токен доступа, потому что я получаю ошибку в методе FixedCredentialsProvider.create, в то время как ...
вопрос задан: 18 January 2019 13:35
1
ответ

Как цепочка Наблюдаемые динамически с помощью итерабельного / списка?

В настоящее время я использую RxJava, и у меня есть что-то вроде этого: List & lt; Integer & gt; taskIds = ... Observable.just (новая задача (taskIds.get (0))) .compose (executeWorkFlow ()) .filter (Response :: ...
вопрос задан: 13 July 2018 20:46
1
ответ

RxJava2, Как совместить результат нескольких наблюдаемых?

Я разрабатываю приложение для Android. У меня вопрос о RxJava2. Вот пример: у меня есть список идентификаторов пользователя. (1, 2, 3, 4, 5, ...) val userIds = listOf (1, 2, 3, 4, 5) Я хочу составить список пользователей ...
вопрос задан: 13 July 2018 08:09
1
ответ

Использовать случайное наблюдение x количество раз

У меня есть Observable, который реализует обработку ошибок в методе onErrorResumeNext. getMyObservable (params) .take (1) .doOnError (e - & gt; {}) ...
вопрос задан: 13 July 2018 07:17
1
ответ

Как отфильтровать повторяющиеся значения, излучаемые наблюдаемыми в RXJava?

У меня есть коллекция объектов, где я хочу подавить дубликаты. Я знаю об операторе Distinct, но если я не ошибаюсь, он сравнивает элементы правильно переопределенным методом хэш-кода. Но что, если ...
вопрос задан: 29 August 2015 13:04
0
ответов

Как сбросить BehaviorSubject

У меня есть BehaviorSubject, который я хотел бы сбросить - я имею в виду, что хочу, чтобы последнее значение не было доступно, как если бы оно было только что создано. Я не вижу API для этого, но я полагаю ...
вопрос задан: 17 July 2019 13:16
0
ответов

Элегантный способ получить индекс фильтра или сначала с RX Java

Я просто практикую RX Java и хотел получить позицию в массиве для элементов, которые соответствуют фильтру. Я не вижу никакого очевидного способа сделать это. Я смотрел на, возможно, увеличение диапазона и повторяемость ...
вопрос задан: 19 April 2019 13:35
0
ответов

RxJava2 concatMap и concatMapEager от Flowable с наблюдать за имеют различное поведение

Должны ли pubisher.observerOn (планировщик) .concatMap (mapper, 1) и publisher.observerOn (планировщик) .concatMapEager (mapper, 1, 1) работать одинаково, когда concatMapEager использует параллелизм с 1? Я тестирую ...
вопрос задан: 14 April 2019 07:26
0
ответов

RxKotlin - Процесс завершается, когда вызывается dispose

я пытаюсь загрузить изображение через rxkotlin, моя проблема в том, что когда я закрываю экран в приложении, процесс загрузки прекращается, потому что я добавляю эту подписку в мое распоряжение, поэтому
вопрос задан: 20 March 2019 04:14
0
ответов

Отправка изображения и массива в Retrofit с использованием Multipart в Retrofit

Я пытаюсь отправить изображение и массив, используя multipart. Я успешно загрузил изображение, используя multipart, но не смог отправить массив с ним. интерфейс @Multipart @ retrofit2.http.POST ("/" + ...
вопрос задан: 18 March 2019 16:02
0
ответов

Динамическая библиотека создателей CSV

У меня есть несколько Observables данных, которые поступают в виде объекта с тремя свойствами: отметка времени, метка и значение. Мне нужно создать один файл CSV из всех них (и отправить его пользователю после вызова REST) ​​...
вопрос задан: 11 March 2019 14:27
0
ответов

Robolectric реактивная блокировка First () иногда зависает

Этот тест выглядит нормально и работает нормально. Тем не менее, иногда это занимает навсегда метод blockingFirst (). @Test fun test_getScenarioModel () {doReturn (MockDownloader ({File ("abc.zip")})) ....
вопрос задан: 17 January 2019 05:27
0
ответов

RxJava: Блокирование одного против Блокирования первым

Я никогда не мог понять разницу между blockingSingle и blockingFirst в Observables в RxJava. Любая помощь будет принята с благодарностью.
вопрос задан: 16 January 2019 06:49
0
ответов

Выделенные потоки ReactiveX и синглы не выделяют элементы

Я тестирую некоторые функции, основанные на RxJava, используя Mockito, чтобы имитировать объекты. У меня есть место, где мне нужно высмеять значение для возвращаемого метода, который является Single & lt; HttpResponse & lt; Buffer & gt; & gt; & gt; но .
вопрос задан: 13 July 2018 11:25
0
ответов

RxJava takeUntil с выбросом последнего элемента?

Есть ли возможность выбросить элемент, который соответствует условию в операторе takeUntil?
вопрос задан: 9 February 2018 08:57
0
ответов

Разница между vert.x и RxJava

Мы оцениваем рамки реактивного программирования для одного из наших проектов. Я только что прошел учебники по vert.x. Я немного проверил презентацию RxJava. RxJava казался ближе к CompletableFuture. Но ...
вопрос задан: 24 May 2017 17:19
0
ответов

Использование RxJava и Okhttp

Я хочу запросить URL-адрес, используя okhttp в другом потоке (например, поток ввода-вывода), и получить ответ в основном потоке Android, но я не знаю, как создать Observable.
вопрос задан: 6 June 2016 13:15
0
ответов

Есть ли у нас возможность остановить запрос в OkHttp Interceptor?

В нашем приложении мы встретились с одним особым случаем - если наш App.specialFlag == true, нам нужно остановить любой запрос из нашего кода. И мы думаем, что лучшим подходом в этой ситуации является использование специального перехватчика ...
вопрос задан: 31 May 2016 08:29