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,此后每个时间段后发出不断增加的数字。