RxJava

Question 1

Какой класс предпочтительно использовать использовать для тестирования RxJava?

Answer 1

TestSubscriber

Question 2

Какие преимущества дает TestSubscriber по сравнению с традиционным тестированием?

Answer 2

Традиционный подход - упускает одно из самых больших преимуществ RxJava - обработка событий в отдельных потоках.
RxJava поставляется с классом TestSubsriber, который позволяет нам писать тесты, которые работают с асинхронной обработкой событий.

Question 3

Что такое RxJava

Answer 3

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

Question 4

Какие свойства есть у Библиотеки RxJava?

Answer 4

• Интуитивность
  Действия в Rx описываются в таком же стиле, как и в других библиотеках вдохновленных функциональным программированием, например, Java Streams. Rx дает возможность использовать функциональные трансформации над потоками событий.

-Расширяемость
RxJava может быть расширена пользовательскими операторами.

-Декларативность
Функциональные трансформации обьявлены декларативно.

-Компонуемость
Операторы в Rx легко компонуются, чтобы проводить сложные операции.

-Преобразуемость
Операторы в Rx могут трансформировать типы данных, фильтруя, обрабатывая и расширяя потоки данных при необходимости.

Question 5

Когда следует использовать Rx?

Answer 5

Rx применяется для составления и обработки последовательностей событий.

Следует использовать Rx

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

Question 6

Когда не следует использовать Rx?

Answer 6

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

Question 7

Основные типы RxJava?

Какие типы добавили в RxJava2?

Answer 7

Signle, Observable и Observer, Flowabble,Subjects и Processors, Subscriber и Subscription, Maybe

Question 8

Как RxJava 2 обрабатывает Null

Answer 8

RxJava 2.x больше не приемлет значения NULL, и следующий код приведет к немедленному получению NullPointerException, или Emitter(порождающий поток) выбросит onError-событие.

Question 9

В чем разница между Observable и Flowable?

Answer 9

Observable — класс без покрытия backpressure, а Flowable наделен backpressure. Backpressure(Обратное давление) — явление, которое можно встретить в порождающем потоке, где некоторые асинхронные операции не могут обрабатывать значения достаточно быстро и нуждаются в замедлении работы производителя.
когда юзать Observable

Observable -В тех кейсах, когда у вас в итерации, не более 1000 элементов. В остальных flowable

Question 10

Какой тип хорошо подходит для обработки одиночного сетевого запроса?

Answer 10

Signle

Question 11

Что делает unsubscribe? Когда его применять?

Answer 11

Вызов unsubscribe остановит поступление событий в observer.

Question 12

Что делает Observable.interval?

Answer 12

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

Question 13

Что делает Observable.range?

Answer 13

Выдает значения из заданного диапазона.

Question 14

Можно ли применять unsubscribe к Single? Почему

Answer 14

Да т.к. неизвестно когда Single получит результат.