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

1. Введение​

В этом руководстве мы рассмотрим тип Maybe<T> в RxJava, который представляет собой поток, который может выдать одно значение, завершиться в пустом состоянии или сообщить об ошибке .

2. Тип « может быть » ​

Maybe — это особый тип Observable , который может выдавать только один или ноль элементов и сообщать об ошибке, если в какой-то момент вычисление завершается неудачно.

В этом отношении это похоже на объединение Single и Completable . Все эти сокращенные типы, включая Maybe, предлагают подмножество операторов Flowable . Это означает , что мы можем работать с Maybe как с Flowable , пока операция имеет смысл для 0 или 1 элементов.

1. Обзор​

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

Но сначала давайте посмотрим на поведение нескольких подписчиков по умолчанию.

2. Поведение по умолчанию​

Допустим, у нас есть следующий Observable :

1. Обзор​

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

Оператор — это функция, которая принимает и изменяет поведение вышестоящего Observable<T> и возвращает нижестоящий Observable<R> или Subscriber , где типы T и R могут совпадать, а могут и не совпадать.

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

2. Делай​

1. Обзор​

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

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

Мы можем получить Scheduler из фабричных методов, описанных в классе Schedulers .

2. Поведение потоков по умолчанию​

1. Введение в StringObservable​

Работа с последовательностями строк в RxJava может быть сложной; к счастью , RxJavaString предоставляет нам все необходимые утилиты.

В этой статье мы рассмотрим StringObservable , который содержит несколько полезных строковых операторов. Поэтому, прежде чем приступить к работе, рекомендуется сначала ознакомиться с введением в RxJ ava .

2. Настройка Мавена​

Для начала давайте включим RxJavaString в число наших зависимостей:

1. Обзор​

В этом руководстве мы подробно рассмотрим тестирование реактивных потоков с помощью StepVerifier и TestPublisher .

Мы будем основывать наше исследование на приложении Spring Reactor , содержащем цепочку операций реактора.

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

Spring Reactor поставляется с несколькими классами для тестирования реактивных потоков.

1. Обзор​

В этом руководстве показано, как создать простое реактивное приложение Spring Boot, которое интегрируется с сервером обмена сообщениями RabbitMQ, популярной реализацией стандарта обмена сообщениями AMQP.

Мы рассмотрим оба сценария — «точка-точка» и «публикация-подписка» — с использованием распределенной установки, которая подчеркивает различия между обоими шаблонами.

Обратите внимание, что мы предполагаем базовые знания AMQP, RabbitMQ и Spring Boot, в частности, таких ключевых понятий, как обмены, очереди, темы и так далее. Более подробную информацию об этих концепциях можно найти по ссылкам ниже:

• Обмен сообщениями с Spring AMQP
• Введение в RabbitMQ

2. Настройка сервера RabbitMQ​

1. Обзор​

Использование фильтров широко распространено в веб-приложениях, поскольку они дают нам возможность изменять запрос или ответ без изменения наших конечных точек.

В этом кратком руководстве мы опишем возможные способы их реализации с помощью WebFlux Framework.

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

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

1. Обзор​

В этой статье мы рассмотрим библиотеку akka-streams , созданную поверх фреймворка актеров Akka, которая соответствует манифесту реактивных потоков . Akka Streams API позволяет нам легко составлять потоки преобразования данных из независимых шагов.

Более того, вся обработка выполняется реактивным, неблокирующим и асинхронным способом.

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

Для начала нам нужно добавить библиотеки akka-stream и akka-stream-testkit в наш pom.xml:

1. Введение​

В этой статье мы сосредоточимся на интеграции Akka с Spring Framework, чтобы разрешить внедрение сервисов на основе Spring в актеры Akka.

Перед чтением этой статьи рекомендуется предварительно ознакомиться с основами Akka.

2. Внедрение зависимостей в Akka​