RxJava-유틸리티 연산자

다음은 Observable에서 자주 유용한 연산자입니다.

Sr. 아니.	연산자 및 설명
1	Delay Observable 수명주기 이벤트를 처리하는 작업을 등록합니다.
2	Materialize/Dematerialize 방출 된 항목 및 전송 된 알림을 나타냅니다.
삼	ObserveOn 관찰 할 스케줄러를 지정하십시오.
4	Serialize Observable이 직렬화 된 호출을 수행하도록 강제합니다.
5	Subscribe Observable에서 완료되는 것과 같은 항목 및 알림의 방출에 대해 작동합니다.
6	SubscribeOn 구독 할 때 Observable에서 사용할 스케줄러를 지정하십시오.
7	TimeInterval Observable을 변환하여 배출 사이에 경과 된 시간의 양을 표시합니다.
8	Timeout 항목을 내 보내지 않고 지정된 시간이 발생하면 오류 알림을 발행합니다.
9	Timestamp 내 보낸 각 항목에 타임 스탬프를 첨부합니다.
9	Using 일회용 리소스 또는 Observable과 동일한 수명을 만듭니다.

유틸리티 운영자의 예

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

ObservableTester.java

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