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) − 将数组转换为一个 ObservableSource，该数组发出数组中的项目。

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

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

• interval(long initialDelay, long period, TimeUnit unit) − 返回一个 Observable，它在 initialDelay 后发出 0L，并在其后的每个时间段后发出不断增加的数字。