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