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

결과 확인

다음을 사용하여 클래스 컴파일 javac 다음과 같이 컴파일러-

C:\RxJava>javac ObservableTester.java

이제 다음과 같이 ObservableTester를 실행하십시오.

C:\RxJava>java ObservableTester

다음 출력을 생성해야합니다.

ab