RxJava - Toán tử Tiện ích

Sau đây là các toán tử thường hữu ích với Observables.

Sr.No.	Nhà điều hành & Mô tả
1	Delay Đăng ký hành động để xử lý các sự kiện vòng đời có thể quan sát được.
2	Materialize/Dematerialize Đại diện cho mục được phát ra và thông báo được gửi.
3	ObserveOn Chỉ định bộ lập lịch được quan sát.
4	Serialize Buộc có thể quan sát để thực hiện các cuộc gọi tuần tự.
5	Subscribe Hoạt động dựa trên việc phát thải các mục và thông báo giống như hoàn thành từ một thiết bị có thể quan sát
6	SubscribeOn Chỉ định bộ lập lịch sẽ được sử dụng bởi một Observable khi nó được đăng ký.
7	TimeInterval Chuyển đổi một có thể quan sát để phát ra các chỉ báo về khoảng thời gian đã trôi qua giữa các lần phát xạ.
số 8	Timeout Đưa ra thông báo lỗi nếu xảy ra thời gian cụ thể mà không phát ra bất kỳ mục nào.
9	Timestamp Đính kèm dấu thời gian cho mỗi mục được phát ra.
9	Using Tạo tài nguyên dùng một lần hoặc cùng tuổi thọ với tài nguyên có thể quan sát được.

Ví dụ về toán tử tiện ích

Tạo chương trình Java sau bằng bất kỳ trình soạn thảo nào bạn chọn trong 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);
   }
}