FirstExample.java

import io.reactivex.rxjava3.core.Observable;

public class FirstExample {
    public void emit() {
        Observable.just("Hello", "RxJava 2!!")
                .subscribe(System.out::println);
    }

    public static void main(String[] args) {
        FirstExample demo = new FirstExample();
        demo.emit();
    }
}

Observable 클래스

데이터 변화가 발생하는 데이터 소스이다.

just 함수

가장 단순한 Observable선언 방식이다. 위 코드에서 'Hello'와 'RxJava 2!!'를 발행했다.
Integer같은 래퍼 타입부터 사용자 정의 클래스 객체도 인자로 사용 가능하다.

subscribe 함수

Observable을 구독한다. Observable은 subscribe() 함수를 호출해야 변화한 데이터를 구독자에게 발행한다. (Like 옵저버 패턴)

System.out::println

수신한 데이터를 System.out::println를 통해 호출한다. 자바8 메서드 레퍼런스를 활용한 것으로, 메서드 레퍼런스를 사용하지 않으면

data -> System.out.println(data)

와 동일하다. Observable이 발행하는 데이터는 data 인자로 들어온다.