rx-java- все статьи тега


Очередь как тема в RxJava

Я ищу предмет (или что-то подобное), который может: может принимать элементы и удерживать их в очереди или буфере, если нет подписчиков Как только у нас есть подписчик, все элементы потребляются и никогда не испускаются снова я могу подписаться/отписаться от темы BehaviorSubject почти выполнила бы задание, но при этом сохранила бы последний наблюдаемый пункт. Обновить Основываясь на принятом ответе, я разработал аналогичное решение для одного наблюдаемый пункт. Также добавлена часть о ...

RxJava, хороший пример использования flatmap

Я новичок в RxJava, часто путаюсь в функции flatMap. Согласно doc, flatmap transform the items emitted by an Observable into Observables, then flatten the emissions from those into a single Observable Может ли кто - нибудь привести хороший пример его использования? Зачем превращать исходное наблюдаемое в наблюдаемое (множественное число), а затем превращать их в единое наблюдаемое? Почему бы вам просто не использовать "карту"? Если вы приведете пример в Android, это потрясающе, в противном ...

Rx Java mergeDelayError не работает как ожидалось

Я использую RxJava в и Android-приложение с RxAndroid. Я использую mergeDelayError, чтобы объединить две сети ретро подходят звонков в одной наблюдаемой, которая будет обрабатывать выбрасываемых элементов, если дает один и об ошибках, если есть. Это не работает, и он только запускает действие onError, когда либо сталкивается с ошибкой. Теперь, чтобы проверить это, я перешел к очень простому примеру, и все же successAction никогда не вызывается, когда у меня есть вызов onError. Смотрите пример по ...

Когда вы используете map vs flatMap в RxJava?

когда вы используете map vs flatMap в RxJava? скажем, например, мы хотим сопоставить файлы, содержащие JSON, в строки, содержащие JSON-- используя карту, мы должны как-то справиться с исключением. Но как?: Observable.from(jsonFile).map(new Func1<File, String>() { @Override public String call(File file) { try { return new Gson().toJson(new FileReader(file), Object.class); } catch (FileNotFoundException e) { // So Exception. What to do ? ...

Разница между потоками Java 8 и наблюдаемыми RxJava

являются ли потоки Java 8 похожими на наблюдаемые RxJava? Java 8 определение потока: классы в новом java.util.stream пакет предоставляет API потока для поддержка операций функционального стиля над потоками элементов. ...

Получить код статуса ответа с использованием модифицированной версии 2.0 и RxJava

Я пытаюсь обновить до Retrofit 2.0 и добавить RxJava в мой проект android. Я делаю вызов api и хочу получить код ошибки в случае ответа на ошибку с сервера. Observable<MyResponseObject> apiCall(@Body body); и в RxJava вызов: myRetrofitObject.apiCall(body).subscribe(new Subscriber<MyResponseObject>() { @Override public void onCompleted() { } @Override public void onError(Throwable e) { } @Override public void onN ...

RxJava Выборка Наблюдаемых Параллельно

Мне нужна помощь в реализации параллельных асинхронных вызовов в RxJava. Я выбрал простой случай использования, в котором первый вызов извлекает (а не ищет) список продуктов (плитка), которые будут отображаться. Последующие вызовы выходят и получают (а) обзоры и (б) изображения продукта после нескольких попыток я добрался до этого места. 1 Observable<Tile> searchTile = searchServiceClient.getSearchResults(searchTerm); 2 List<Tile> allTiles = new ArrayList<Tile>(); 3 ...