Краткая памятка по источникам данных в RxJava2. Мало, чётко, по делу.

Observable

Стандартный источник данных. Не поддерживает backpressure.

При желании можно отписаться по disposable.dispose()

Flowable

То же, но с поддержкой backpressure:

Single

Получает один блок данных, без всяких onNext:

Completable

Запускает что-то на выполнение и ждёт результат. Обновление данных на сервере, запись в базу и всякое такое:

Maybe

Помесь Single и Completable. Если что-то вернулось — отлично, отдаётся в onSuccess. Ничего не вернулось — просто выполняем код в onComplete:

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

Закрыть меню