«1. Введение После введения в статью о RxJava мы рассмотрим агрегатные и математические операторы. Эти операции должны ждать, пока исходный Observable выдаст все элементы. Из-за этого эти операторы опасно использовать с Observables, которые могут представлять очень длинные или бесконечные последовательности.
«Наблюдаемые служебные операторы в RxJava»
«1. Обзор В этой статье мы узнаем о некоторых служебных операторах для работы с Observables в RxJava и о том, как реализовать собственные. Оператор — это функция, которая принимает и изменяет поведение вышестоящего Observable\u003cT\u003e и возвращает нижестоящий Observable\u003cR\u003e или Subscriber,
«Преобразование синхронных и асинхронных API в Observables с использованием RxJava2»
«1. Обзор В этом руководстве мы узнаем, как преобразовать традиционные синхронные и асинхронные API в Observables с помощью операторов RxJava2. Мы создадим несколько простых функций, которые помогут нам подробно обсудить эти операторы. 2. Зависимости Maven Во-первых, мы должны добавить RxJava2
«RxJava One Observable, несколько подписчиков»
«1. Обзор Поведение нескольких подписчиков по умолчанию не всегда желательно. В этой статье мы расскажем, как изменить это поведение и правильно обрабатывать несколько подписчиков. Но сначала давайте посмотрим на поведение нескольких подписчиков по умолчанию. 2. Поведение по умолчанию Допустим, у
«RxJava StringObservable»
«1. Введение в StringObservable Работа с последовательностями строк в RxJava может быть сложной; к счастью, RxJavaString предоставляет нам все необходимые утилиты. В этой статье мы рассмотрим StringObservable, который содержит несколько полезных строковых операторов. Поэтому, прежде чем приступить к работе, рекомендуется
«Фильтрация наблюдаемых в RxJava»
«1. Введение После введения в RxJava мы рассмотрим операторы фильтрации. В частности, мы сосредоточимся на фильтрации, пропуске, временной фильтрации и некоторых более сложных операциях фильтрации. 2. Фильтрация При работе с Observable иногда полезно выбрать только подмножество испускаемых элементов. Для этой
«RxJava 2 – текучий»
«1. Введение RxJava — это реализация Reactive Extensions Java, которая позволяет нам писать управляемые событиями и асинхронные приложения. Дополнительную информацию о том, как использовать RxJava, можно найти в нашей вводной статье здесь. RxJava 2 был переписан с нуля, что принесло
«Работа с противодавлением с помощью RxJava»
«1. Обзор В этой статье мы рассмотрим, как библиотека RxJava помогает нам справляться с противодавлением. Проще говоря, RxJava использует концепцию реактивных потоков, вводя Observables, на которые может подписаться один или несколько наблюдателей. Работа с потенциально бесконечными потоками очень сложна, так
«Планировщики в RxJava»
«1. Обзор В этой статье мы сосредоточимся на различных типах Планировщиков, которые будем использовать при написании многопоточных программ на основе методов RxJava Observable subscribeOn иObservable. Планировщики дают возможность указать, где и, вероятно, когда выполнять задачи, связанные с работой цепочки Observable.
«Разница между Flatmap и Switchmap в RxJava»
«1. Обзор RxJava предоставляет различные операторы для преобразования элементов, испускаемых наблюдаемым объектом, в другие наблюдаемые объекты. Двумя наиболее популярными операторами являются flatMap и switchMap. Разницу между ними часто трудно понять новичкам в реактивном программировании. Для ознакомления с RxJava обратитесь к