RxJava 创建Observable

以下是创建 observable 的基类。

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

• Observable ： 0..N 流量，但没有背压。

• Single ： 1 个项目或错误。可以被视为方法调用的反应版本。

• Completable  ： 未发出任何项目。用作完成或错误的信号。可以被视为 Runnable 的反应版本。

• MayBe ：没有项目或 1 个项目发出。可以被视为 Optional 的反应版本。

以下是在 Observable 类中创建 observable 的便捷方法。

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

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

• fromArray(T... items)：将一个数组转换为一个 ObservableSource，它发出数组中的项目。

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

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

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