Ниже приведены базовые классы для создания наблюдаемых.
-
Текучий — 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 и постоянно увеличивающиеся числа после каждого периода времени после этого.