RxJava-연산자 생성

다음은 Observable을 만드는 데 사용되는 연산자입니다.

Sr. 아니.	연산자 및 설명
1	Create Observable을 처음부터 만들고 관찰자 메서드가 프로그래밍 방식으로 호출 할 수 있도록합니다.
2	Defer 옵저버가 구독 할 때까지 Observable을 생성하지 마십시오. 각 옵저버에 대한 새로운 옵저버 블을 생성합니다.
삼	Empty/Never/Throw 제한된 동작으로 Observable을 만듭니다.
4	From 객체 / 데이터 구조를 Observable로 변환합니다.
5	Interval 지정된 시간 간격의 간격을 사용하여 순서대로 정수를 방출하는 Observable을 만듭니다.
6	Just 객체 / 데이터 구조를 Observable로 변환하여 동일하거나 동일한 유형의 객체를 방출합니다.
7	Range 주어진 범위의 순서대로 정수를 방출하는 Observable을 생성합니다.
8	Repeat 반복적으로 정수를 방출하는 Observable을 생성합니다.
9	Start 함수의 반환 값을 내보내는 Observable을 만듭니다.
10	Timer 주어진 지연 후 단일 항목을 방출하는 Observable을 생성합니다.

연산자 예제 만들기

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

ObservableTester.java

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