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);
   }
}

Xác minh kết quả

Biên dịch lớp bằng cách sử dụng javac trình biên dịch như sau -

C:\RxJava>javac ObservableTester.java

Bây giờ hãy chạy ObservableTester như sau:

C:\RxJava>java ObservableTester

Nó sẽ tạo ra kết quả sau:

ABCDEFG