RxJava-조건부 연산자

다음은 하나 또는 여러 개의 Observable 또는 방출 된 항목을 평가하는 연산자입니다.

Sr. 아니.	연산자 및 설명
1	All 주어진 기준을 충족하기 위해 방출 된 모든 항목을 평가합니다.
2	Amb 여러 Observable이 주어진 경우에만 첫 번째 Observable에서 모든 항목을 방출합니다.
삼	Contains Observable이 특정 항목을 방출하는지 여부를 확인합니다.
4	DefaultIfEmpty Observable이 아무것도 방출하지 않으면 기본 항목을 방출합니다.
5	SequenceEqual 두 Observable이 동일한 항목 시퀀스를 방출하는지 확인합니다.
6	SkipUntil 두 번째 Observable이 항목을 방출 할 때까지 첫 번째 Observable이 방출 한 항목을 버립니다.
7	SkipWhile 주어진 조건이 거짓이 될 때까지 Observable에서 내 보낸 항목을 버립니다.
8	TakeUntil 두 번째 Observable이 항목을 방출하거나 종료 한 후 Observable이 방출 한 항목을 버립니다.
9	TakeWhile 지정된 조건이 거짓이 된 후 Observable이 내 보낸 항목을 버립니다.

조건부 연산자 예

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

ObservableTester.java

import io.reactivex.Observable;
//Using defaultIfEmpty operator to operate on an Observable
public class ObservableTester  {
   public static void main(String[] args) {    
      final StringBuilder result = new StringBuilder();
      Observable.empty()
      .defaultIfEmpty("No Data")
      .subscribe(s -> result.append(s));
      System.out.println(result);
      String[] letters = {"a", "b", "c", "d", "e", "f", "g"};
      final StringBuilder result1 = new StringBuilder();
      Observable.fromArray(letters)
      .firstElement()
      .defaultIfEmpty("No data")   
      .subscribe(s -> result1.append(s));
      System.out.println(result1);
   }
}