API Java Flow был представлен в Java 9 как реализация спецификации Reactive Stream.
В этом руководстве мы сначала исследуем реактивные потоки. Затем мы узнаем о его связи с RxJava и Flow API.
Реактивный манифест представил Reactive Streams, чтобы указать стандарт для асинхронной обработки потоков с неблокирующим противодавлением.
RxJava — популярная библиотека для создания асинхронных программ и программ, основанных на событиях. Она черпает вдохновение из основных идей, выдвинутых инициативой Reactive Extensions .
Vert.x , проект под эгидой Eclipse , предлагает несколько компонентов, разработанных с нуля для полного использования реактивной парадигмы.
При совместном использовании они могут стать надежной основой для любой Java -программы, которая должна быть реактивной.
В этой статье мы загрузим файл со списком названий городов и распечатаем для каждого из них продолжительность дня от восхода до заката.
Мы будем использовать данные, опубликованные из общедоступного REST API www.metaweather.com — для расчета продолжительности дневного света и RxJava с Vert.x , чтобы сделать это чисто реактивным способом. ``
Проще говоря, rxjava-jdbc — это API для взаимодействия с реляционными базами данных, который позволяет вызывать методы в стиле Fluent. В этом кратком руководстве мы рассмотрим библиотеку и то, как мы можем использовать некоторые из ее общих функций.
Если вы хотите познакомиться с основами RxJava, ознакомьтесь с этой статьей .
RxJava — это реализация Reactive Extensions для среды Java.
Библиотека использует комбинацию функциональных и реактивных методов, которые могут представлять собой элегантный подход к программированию, управляемому событиями, со значениями, которые меняются со временем, и где потребитель реагирует на данные по мере их поступления.
В этой статье мы рассмотрим, как обрабатывать исключения и ошибки с помощью RxJava.
Во-первых, имейте в виду, что Observable обычно не генерирует исключений. Вместо этого по умолчанию Observable вызывает метод onError() своего наблюдателя , уведомляя наблюдателя о том, что только что произошла неисправимая ошибка, а затем завершает работу, не вызывая больше никаких методов своего наблюдателя .
Операторы обработки ошибок, которые мы собираемся представить, изменяют поведение по умолчанию, возобновляя или повторяя последовательность Observable .
В этой статье основное внимание уделяется тому, как реализовать простой REST-клиент с поддержкой RxJava с помощью Retrofit .
Мы создадим пример приложения, взаимодействующего с GitHub API, используя стандартный подход к модернизации, а затем усовершенствуем его с помощью RxJava, чтобы использовать преимущества реактивного программирования.
Давайте сначала создадим пример с Retrofit. Мы будем использовать API-интерфейсы GitHub, чтобы получить отсортированный список всех участников, которые имеют более 100 вкладов в любом репозитории.
Популярность RxJava привела к созданию множества сторонних библиотек, расширяющих его функциональность.
Многие из этих библиотек были ответом на типичные проблемы, с которыми сталкивались разработчики при использовании RxJava. RxRelay — одно из таких решений.
предметомПроще говоря, Subject действует как мост между Observable и Observer. Поскольку это Observer , он может подписаться на один или несколько Observable и получать от них события.
В этом кратком руководстве мы обсудим различные способы объединения Observables в RxJava.
Если вы новичок в RxJava, обязательно сначала ознакомьтесь с этим вводным руководством .
Теперь, давайте прыгать прямо в.
НаблюдаемыеВ этом кратком руководстве мы покажем, как написать собственный оператор с помощью RxJava .
Мы обсудим, как создать этот простой оператор, а также преобразователь — как в виде класса, так и в виде простой функции.
Во-первых, нам нужно убедиться, что у нас есть зависимость rxjava в pom.xml :
В этой статье мы рассмотрим способы тестирования кода, написанного с использованием RxJava .
Типичный поток, который мы создаем с помощью RxJava, состоит из Observable и Observer. Наблюдаемое — это источник данных, который представляет собой последовательность элементов. Один или несколько наблюдателей подписываются на него для получения генерируемых событий.
Как правило, наблюдатель и наблюдаемые объекты выполняются в отдельных потоках асинхронным образом, что затрудняет тестирование кода традиционным способом.
К счастью, RxJava предоставляет класс TestSubscriber , который дает нам возможность тестировать асинхронный поток, управляемый событиями.