[Из песочницы] Введение в RxJava, часть первая – Вступление: Почему Rx?23.10.2015 17:48

Для следования этой обучающей программе от вас не потребуются знания реактивного или функционального программирования, однако, предполагается наличие базовых знаний Java.

Материал этих статей расчитан на прочтение от начала до конца. Его обьем больше, чем среднего туториала, но меньше чем реальной книги. Мы начнем с самых основ и от раздела к разделу будем переходить к всё более продвинутым сценариям и концепциям. Каждый раздел задумывался самодостаточным и лаконичным для того, чтобы к нему можно было вернуться в будущем.
Примеры к этим материалам доступны в двух видах:

1. Примеры с выводом в консоль (рекоммендовано для читающих в первый раз)
2. Самопроверяющиеся примеры в форме JUnit тестов

• Часть первая – Вступление
  
  1. Почему Rx?
  2. Ключевые типы
  3. Жизненный цикл Observable
• Часть вторая – Последовательности
  
  1. Создание последовательности
  2. Фильтрация последовательности
  3. Исследование
  4. Агрегация
  5. Трансформация последовательностей
• Часть третья – Управление последовательностями
• Часть четвертая – Паралельность

Часть первая – Вступление: Почему Rx?

Пользователи ожидают данных в реальном времени. Они хотят твиты сейчас. Подтвержение заказа сейчас. Им необходимы цены по состоянию на сейчас. Как разработчик, вы нуждаетесь в самонаводящихся сообщениях. Вы не хотите быть блокированным в ожидании результата. Вы хотите, чтобы результат пришел к вам по готовности. Даже более того, вы хотите работать с результатом по частям: вы не хотите ждать пока загрузится всё перед тем как отобразить первую строку. Мир перешел в режим уведомлений. У разработчиков есть инструменты, чтобы уведомлять, это легко. Им нужны инструменты чтобы реагировать на уведомления.

• Интуитивность
  
  • Действия в Rx описываются в таком же стиле, как и в других библиотеках вдохновленных функциональным программированием, например, Java Streams. Rx дает возможность использовать функциональные трансформации над потоками событий.
  
  
• Расширяемость
  
  • RxJava может быть расширена пользовательскими операторами. И хотя Java не позволяет сделать это элегантным образом, RxJava предлагает всю расширяемость доступную в реализациях Rx на любом другом языке.
  
  
• Декларативность
  
  • Функциональные трансформации обьявлены декларативно.
  
  
• Компонуемость
  
  • Операторы в Rx легко компонуются, чтобы проводить сложные операции.
  
  
• Преобразуемость
  
  • Операторы в Rx могут трансформировать типы данных, фильтруя, обрабатывая и расширяя потоки данных при необходимости.
  
  

• UI события, такие как mouse move, button click
• События вроде изменения свойства, обновления коллекции, «Заказ оформлен», «Регистрация закончена» и т.д.
• Инфраструктурные события (сообщения от системы, WMI или файловых менеджеров)
• Интеграция с событиями от шины сообщений (message bus), сообщениями из WebScoket API)
• Интеграция с CEP-системами (StreamInsight, StreamBas)

• Результат Future или похожего паттерна

• Для превращения Iterable в Observable только для того, чтобы работать с ними через библиотеку Rx.

В следующей части мы рассмотрим фундаментальные типы, на которых основана концепция реактивного программирования: Observable и Observer.

• ↑

  —

  ↓

• 376

• Добавить в избранное 8