Учебники

RxJava – Создание наблюдаемых

Ниже приведены базовые классы для создания наблюдаемых.

  • Текучий – 0..N потоков, испускает 0 или n элементов. Поддерживает Reactive-Streams и обратное давление.

  • Наблюдаемый – 0..N течет, но нет обратного давления.

  • Одиночный – 1 предмет или ошибка. Может рассматриваться как реактивная версия вызова метода.

  • Completable – пункт не выброшен Используется как сигнал для завершения или ошибки. Может рассматриваться как реактивная версия Runnable.

  • MayBe – Либо нет предмета, либо 1 предмет выброшен. Может рассматриваться как реактивная версия Optional.

Текучий – 0..N потоков, испускает 0 или n элементов. Поддерживает Reactive-Streams и обратное давление.

Наблюдаемый – 0..N течет, но нет обратного давления.

Одиночный – 1 предмет или ошибка. Может рассматриваться как реактивная версия вызова метода.

Completable – пункт не выброшен Используется как сигнал для завершения или ошибки. Может рассматриваться как реактивная версия Runnable.

MayBe – Либо нет предмета, либо 1 предмет выброшен. Может рассматриваться как реактивная версия Optional.

Ниже приведены удобные методы для создания наблюдаемых в классе Observable.

just (T item) – Возвращает Observable, который сигнализирует о данном (постоянная ссылка) элементе и затем завершается.

fromIterable (Iterable source) – преобразует последовательность Iterable в ObservableSource, который испускает элементы в последовательности.

fromArray (T … items) – преобразует массив в ObservableSource, который испускает элементы в массиве.

fromCallable (Callable supplier) – возвращает Observable, который, когда наблюдатель подписывается на него, вызывает указанную вами функцию и затем генерирует значение, возвращаемое этой функцией.

fromFuture (Будущее будущее) – преобразует будущее в ObservableSource.

интервал (long initialDelay, long period, TimeUnit unit) – Возвращает наблюдаемое, которое испускает 0L после initialDelay и постоянно увеличивающиеся числа после каждого периода времени после этого.