RxJava - 创建 Observables

以下是创建可观察量的基类。

• Flowable - 0..N 个流，发出 0 或 n 个项目。支持反应流和背压。

• 可观察- 0..N 流量，但没有背压。

• 单一- 1 项或错误。可以被视为方法调用的反应式版本。

• 可完成- 没有发出任何项目。用作完成或错误的信号。可以被视为 Runnable 的响应式版本。

• MayBe - 没有发出任何物品或发出 1 个物品。可以被视为可选的响应式版本。

以下是在 Observable 类中创建可观察对象的便捷方法。

• just(T item) - 返回一个 Observable，它指示给定的（常量引用）项，然后完成。

• fromIterable(Iterable source) - 将 Iterable 序列转换为发出序列中项目的 ObservableSource。

• fromArray(T... items) - 将数组转换为发出数组中项目的 ObservableSource。

• fromCallable(Callable seller) - 返回一个 Observable，当观察者订阅它时，调用您指定的函数，然后发出从该函数返回的值。

• fromFuture(Future future) - 将 Future 转换为 ObservableSource。

• Interval(longinitialDelay, long period, TimeUnitunit) - 返回一个 Observable，它在初始延迟后发出 0L，并在其后的每个时间段后发出不断增加的数字。