Основы реактивного программирования (RxJava RxAndroid)

Основы реактивного программирования

Для начала определимся с терминами. У реактивного программирования существет свой манифест. Можно ознакомиться с переводом на хабре Реактивный манифест. Базовыми строительными блоками реактивного кода являются Observables и Subscribers. Observable является источником данных, а Subscriber — потребителем. Создание  

  • just( ) — оборачивает значение в Observable объект или несколько объектов
  • from( ) — оборачивает Iterable,  Future или Array в Observable
  • repeat( ) — create an Observable that emits a particular item or sequence of items repeatedly
  • repeatWhen( ) — create an Observable that emits a particular item or sequence of items repeatedly, depending on the emissions of a second Observable
  • create( ) — позволяет создавать собственные Observable
  • defer( ) — do not create the Observable until a Subscriber subscribes; create a fresh Observable on each subscription
  • range( ) —  Observable задает интервалы множества элементов
  • interval( ) — create an Observable that emits a sequence of integers spaced by a given time interval
  • timer( ) — Observable испускает элементы после задержки
  • empty( ) — пустой Observable
  • error( ) — Observable  для которого сразу вызывается onError
  • never( ) — последовательность, для которой ничего не вызывается

 

Практика.

Для практики рекомендую посмотреть статью о том как подключить лямбда выражения в Android Sudio.

just:

 D/RxTestLog: Раз  D/RxTestLog: Два  D/RxTestLog: Три

label, , , ,

Добавить комментарий