RxJava - Tạo toán tử

Sau đây là các toán tử được sử dụng để tạo một Observable.

Sr.No.	Nhà điều hành & Mô tả
1	Create Tạo một phương thức có thể quan sát từ đầu và cho phép phương thức quan sát viên gọi theo chương trình.
2	Defer Không tạo một Người quan sát cho đến khi một Người quan sát đăng ký. Tạo ra một quan sát mới cho mỗi người quan sát.
3	Empty/Never/Throw Tạo một Hành vi có thể quan sát được với hành vi hạn chế.
4	From Chuyển đổi đối tượng / cấu trúc dữ liệu thành có thể quan sát được.
5	Interval Tạo một số nguyên phát ra có thể quan sát theo trình tự với khoảng cách khoảng thời gian được chỉ định.
6	Just Chuyển đổi một đối tượng / cấu trúc dữ liệu thành một Có thể quan sát để phát ra cùng một loại hoặc cùng một loại đối tượng.
7	Range Tạo một số nguyên phát ra có thể quan sát theo trình tự của dải ô đã cho.
số 8	Repeat Tạo một số nguyên phát ra có thể quan sát được liên tiếp nhiều lần.
9	Start Tạo một Observable để phát ra giá trị trả về của một hàm.
10	Timer Tạo một mục có thể quan sát để phát ra một mục sau độ trễ nhất định.

Tạo ví dụ về toán tử

Tạo chương trình Java sau đây bằng cách sử dụ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 fromArray operator to create 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
         .map(String::toUpperCase)
         .subscribe( letter -> result.append(letter));
      System.out.println(result);
   }
}