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