RxJava-필터링 연산자

다음은 Observable에서 항목을 선택적으로 내보내는 데 사용되는 연산자입니다.

Sr. 아니.	연산자 및 설명
1	Debounce 다른 항목을 내 보내지 않고 시간 초과가 발생한 경우에만 항목을 내 보냅니다.
2	Distinct 고유 한 항목 만 방출합니다.
삼	ElementAt Observable에 의해 방출 된 n 인덱스에서만 항목을 방출합니다.
4	Filter 주어진 술어 함수를 전달하는 항목 만 내 보냅니다.
5	First 주어진 기준을 통과 한 첫 번째 항목 또는 첫 번째 항목을 내 보냅니다.
6	IgnoreElements Observable에서 항목을 내 보내지 않고 완료를 표시합니다.
7	Last Observable에서 마지막 요소를 내 보냅니다.
8	Sample 주어진 시간 간격으로 가장 최근 항목을 내 보냅니다.
9	Skip Observable에서 처음 n 개 항목을 건너 뜁니다.
10	SkipLast Observable에서 마지막 n 개 항목을 건너 뜁니다.
11	Take Observable에서 처음 n 개 항목을 가져옵니다.
12	TakeLast Observable에서 마지막 n 개 항목을 가져옵니다.

필터링 연산자 예

C : \> RxJava에서 원하는 편집기를 사용하여 다음 Java 프로그램을 만듭니다.

ObservableTester.java

import io.reactivex.Observable;
//Using take operator to filter 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
         .take(2)
         .subscribe( letter -> result.append(letter));
      System.out.println(result);
   }
}