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

결과 확인

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

C:\RxJava>javac ObservableTester.java

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

C:\RxJava>java ObservableTester

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

ABCDEFG