72 записи с тегом "Reactive"

1. Обзор​

В этом уроке мы узнаем о хуках RxJava . Мы создадим короткие примеры, чтобы продемонстрировать, как хуки работают в разных ситуациях.

2. Что такое хуки RxJava?​

Как следует из названия, хуки RxJava позволяют нам подключаться к жизненному циклу Observable, Completable , Maybe , Flowable и Single . Кроме того, RxJava позволяет нам добавлять хуки жизненного цикла к планировщикам, возвращаемым планировщиками. Кроме того, мы можем указать глобальный обработчик ошибок, также используя хуки.

В RxJava 1 для определения хуков используется класс RxJavaHooks . Но механизм перехвата полностью переписан в RxJava 2. Теперь класс RxJavaHooks больше не доступен для определения перехватчиков. Вместо этого мы должны использовать RxJavaPlugins для реализации хуков жизненного цикла .

1. Обзор​

С Spring Boot 2 и новым неблокирующим сервером Netty у нас больше нет контекстного API сервлета, поэтому давайте обсудим, как мы можем выражать различные типы кодов состояния HTTP, используя новый стек.

2. Статус семантического ответа​

Следуя стандартной практике RESTful, нам, естественно, необходимо использовать весь диапазон кодов состояния HTTP, чтобы правильно выразить семантику API.

2.1. Статус возврата по умолчанию​

1. Обзор​

В этой статье мы сосредоточимся на использовании Reactive Extensions (Rx) в Java для создания и использования последовательностей данных.

На первый взгляд API может показаться похожим на Java 8 Streams, но на самом деле он гораздо более гибкий и плавный, что делает его мощной парадигмой программирования.

Если вы хотите узнать больше о RxJava, ознакомьтесь с этой статьей .

2. Настройка​

1. Введение​

RxJava — это реализация Java Reactive Extensions, которая позволяет нам писать управляемые событиями и асинхронные приложения. Дополнительную информацию о том, как использовать RxJava, можно найти в нашей вводной статье здесь .

RxJava 2 был переписан с нуля, что принесло множество новых функций; некоторые из них были созданы в ответ на проблемы, существовавшие в предыдущей версии фреймворка.

Одной из таких функций является io.reactivex.Flowable .

2. Наблюдаемый vs. _ Текучий​

1. Обзор​

В этом руководстве мы узнаем , как преобразовать традиционные синхронные и асинхронные API в Observables с помощью операторов RxJava2 .

Мы создадим несколько простых функций, которые помогут нам подробно обсудить эти операторы.

2. Зависимости Maven​

Во- первых, мы должны добавить RxJava2 и RxJava2Extensions в качестве зависимостей Maven:

1. Обзор​

В этом руководстве мы поиграем с Completable типом RxJava , который представляет результат вычисления без фактического значения. ``

2. Зависимость RxJava​

Давайте включим зависимость RxJava 2 в наш проект Maven:

<dependency>
    <groupId>io.reactivex.rxjava2</groupId>
    <artifactId>rxjava</artifactId>
    <version>2.2.2</version>
</dependency>

1. Обзор​

В этой статье мы рассмотрим, как библиотека RxJava помогает нам справляться с противодавлением.

Проще говоря, RxJava использует концепцию реактивных потоков, вводя Observables, на которые может подписаться один или несколько наблюдателей . Работа с потенциально бесконечными потоками очень сложна, так как нам нужно столкнуться с проблемой противодавления.

Несложно попасть в ситуацию, когда Observable выдает элементы быстрее, чем подписчик может их потреблять. Мы рассмотрим различные решения проблемы растущего буфера неиспользованных предметов.

2. Горячие наблюдаемые против холодных наблюдаемых​

1. Введение​

После введения в RxJava мы рассмотрим операторы фильтрации.

В частности, мы сосредоточимся на фильтрации, пропуске, временной фильтрации и некоторых более сложных операциях фильтрации.

2. Фильтрация​

При работе с Observable иногда бывает полезно выбрать только подмножество испускаемых элементов. Для этой цели RxJava предлагает различные возможности фильтрации .

1. Обзор​

RxJava предоставляет различные операторы для преобразования элементов, испускаемых наблюдаемым объектом, в другие наблюдаемые объекты. Двумя наиболее популярными операторами являются flatMap и switchMap . Разницу между ними часто трудно понять новичкам в реактивном программировании.

Для ознакомления с RxJava обратитесь к этой статье .

В этом уроке мы поймем разницу, рассмотрев простой пример.

2. плоская карта​

1. Введение​

После введения в статью о RxJava мы рассмотрим агрегатные и математические операторы.

Эти операции должны ждать, пока исходный Observable выдаст все элементы. Из-за этого эти операторы опасно использовать с Observables , которые могут представлять очень длинные или бесконечные последовательности.

Во-вторых, во всех примерах используется экземпляр TestSubscriber, особая разновидность Subscriber , которую можно использовать для модульного тестирования, выполнения утверждений, проверки полученных событий или переноса имитируемого Subscriber.

Теперь давайте рассмотрим математические операторы.

2. Настройка​