RxJava - Toán tử toán học

Sau đây là các toán tử hoạt động trên toàn bộ các mục được phát ra bởi một Observable.

Sr.No. Nhà điều hành & Mô tả
1

Average

Đánh giá mức trung bình của tất cả các mục và đưa ra kết quả.

2

Concat

Phát ra tất cả các mục từ nhiều Có thể quan sát được mà không cần xen kẽ.

3

Count

Đếm tất cả các mục và đưa ra kết quả.

4

Max

Đánh giá mục có giá trị tối đa của tất cả các mục và đưa ra kết quả.

5

Min

Đánh giá mục có giá trị tối thiểu của tất cả các mục và đưa ra kết quả.

6

Reduce

Áp dụng một chức năng trên mỗi mục và trả về kết quả.

7

Sum

Đánh giá tổng của tất cả các mục và đưa ra kết quả.

Ví dụ về toán tử

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 concat operator to operate on multiple Observables
public class ObservableTester  {
   public static void main(String[] args)  throws InterruptedException {    
      Integer[] numbers = { 1, 2, 3, 4, 5, 6};
      String[] letters = {"a", "b", "c", "d", "e", "f", "g"};
      final StringBuilder result = new StringBuilder();
      Observable<String> observable1 = Observable.fromArray(letters);
      Observable<Integer> observable2 = Observable.fromArray(numbers);
      Observable.concat(observable1, observable2)
         .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:

abcdefg123456