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，並在其後的每個時間段後發出不斷增加的數字。