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

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