Rxjava 简明教程

RxJava - Creating Observables

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

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

  2. Observable − 0..N 次流，但无背压。

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

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

  5. MayBe − 不发出任何项目或发出 1 个项目。可以视为 Optional 的响应版本。

以下是 Observable 类中创建可观察序列的便利方法。

  1. just(T item) − 返回一个 Observable，它对给定的（常量引用）项目发出信号，然后完成。

  2. fromIterable(Iterable source) − 将可迭代序列转换为 ObservableSource，它发出序列中的项目。

  3. fromArray(T…​ items) − 将数组转换为 ObservableSource，它发出数组中的项目。

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

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

  6. interval(long initialDelay, long period, TimeUnit unit) − 返回一个 Observable，它在初始延迟后发出 0L，并在此之后，每隔一段时间就发出递增的数字。