RxJava - 创建可观察对象

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

  • Flowable − 0..N 流,发出 0 或 n 个项目。支持 Reactive-Streams 和背压。

  • Observable − 0..N 流,但没有背压。

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

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

  • MayBe −要么不发射任何项目,要么发射 1 个项目。可以视为 Optional 的反应版本。

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

  • just(T item) − 返回一个 Observable,该 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,此后每个时间段后发出不断增加的数字。