极客教程RxJava 创建 Observables
以下是创建 Observables 的基本类。
- Flowable − 0..N 个流，可发出 0 或 n 个项。支持 Reactive-Streams 和背压。
-
Observable − 0..N 个流，无背压。
-
Single − 1 个项或错误。可视为方法调用的响应式版本。
-
Completable − 不发出任何项。用作完成或错误的信号。可视为 Runnable 的响应式版本。
-
MayBe − 要么不发出任何项，要么发出 1 个项。可视为 Optional 的响应式版本。
以下是在 Observable 类中创建 Observables 的便捷方法。
-
just(T item) − 返回一个 Observable，它发出给定的（常量引用）项，然后完成。
-
fromIterable(Iterable source) − 将 Iterable 序列转换为发出序列中的项的 ObservableSource。
-
fromArray(T… items) − 将 Array 转换为发出数组中的项的 ObservableSource。
-
fromCallable(Callable supplier) − 返回一个 Observable，在观察者订阅它时，调用您指定的函数，然后发出该函数返回的值。
-
fromFuture(Future future) − 将 Future 转换为 ObservableSource。
-
interval(long initialDelay, long period, TimeUnit unit) − 返回一个 Observable，在 initialDelay 后发出一个 0L，并且在之后每个时间段后发出递增的数字。