RxJava - 實用運算子

以下是與可觀察物件經常一起使用的運算子。

序號	運算子及描述
1	延時 (Delay) 註冊操作以處理可觀察物件的生命週期事件。
2	Materialize/Dematerialize 表示發射的專案和傳送的通知。
3	ObserveOn 指定要觀察的排程器。
4	Serialize 強制可觀察物件進行序列化呼叫。
5	Subscribe 對可觀察物件的專案發射和通知（如完成）進行操作。
6	SubscribeOn 指定可觀察物件訂閱時使用的排程器。
7	TimeInterval 將可觀察物件轉換為發射專案之間經過時間的指示。
8	Timeout 如果在指定時間內沒有發射任何專案，則發出錯誤通知。
9	Timestamp 為每個發射的專案附加時間戳。
9	使用 (Using) 建立一個與可觀察物件具有相同生命週期的可丟棄資源。

實用運算子示例

使用您選擇的任何編輯器建立以下 Java 程式，例如在 C:\>RxJava 中。

ObservableTester.java

import io.reactivex.Observable;
//Using subscribe operator to subscribe to an Observable
public class ObservableTester  {
   public static void main(String[] args) {    
      String[] letters = {"a", "b", "c", "d", "e", "f", "g"};
      final StringBuilder result = new StringBuilder();
      Observable<String> observable = Observable.fromArray(letters);
      observable.subscribe( letter -> result.append(letter));
      System.out.println(result);
   }
}

驗證結果

使用javac編譯器編譯類，如下所示：

C:\RxJava>javac ObservableTester.java

現在執行 ObservableTester，如下所示：

C:\RxJava>java ObservableTester

它應該產生以下輸出：

abcdefg

列印頁面