관찰 가능한 스트림(Observable streams)을 사용하는 비동기 프로그래밍 API이다.

Publisher(데이터를 만들어 통지하는 생산자)와 Subscriber로 구성되어있으며, Subscriber가 Publisher를 구독하면 Publisher가 통보하는 데이터를 받을 수 있다.

Observable : 관찰할 수 있는' 데이터 스트림이다.
Operators (연산자) : 비동기 흐름을 조합하는 실행 단위로 옵저버블을 처리하는 함수이다. 옵저버블로부터 전달받은 데이터를 가공하여 최종적인 결과 데이터를 만들어낸다.
Scheduler : 스레드 관리자
Observer(구독자) : Subscriber, Watcher, Reactor등으로도 불리며, 옵저버블이 발행한 데이터를 구독하는 구독자. 구독하지 않으면 옵저버블이 발행한 데이터를 전달받을 수 없다.

Observable

RxJava에서는 Observable을 구독하는 Observer가 존재한다. Observable은 데이터 흐름에 맞게 알림을 보내 Observer가 데이터를 사용할 수 있도록 한다.

Observable의 특징

Composable Observable은 비동기 데이터의 적절한 흐름과 순서를 구성할 수 있다.
Flexible Observable은 단순한 scalar 값 뿐만 아니라 무한한 스트림을 차례로 발행할 수 있다.
Less Opinionated Observable은 데이터 소스가 Concurrency이던 Asynchronicity이던 상관없다. Observable은 Thread-pool, Event Loop, Non-Blocking I/O 등 다양한 방식을 통해 구현될 수 있다.

Observable 생성

Observable을 생성할 때에는 직접 인스턴스를 만들지 않고 정적 팩토리 함수(생성 연산자)를 호출한다.

* Observable은 팩토리 함수로 데이터 흐름을 정의한 후 subscribe() 함수를 호출해야 실제로 데이터를 발행한다.

just() 인자로 넣은 데이터를 있는 그대로 차례로 발행한다. (데이터를 인자로 넣으면 자동으로 알림 이벤트가 발생) 한 개의 값을 넣을 수도 있고 인자로 여러 개의 값(동일한 타입, 최대 10개)을 넣을 수도 있다. 데이터를 다르게 변경하고 싶으면 map()과 같은 연산자를 통해 변환해야한다.
create() Emitter에 포함되어 있는 onNext(), onComplete(), onError() 같은 알림을 개발자가 직접 호출해야 한다.
- OnNext() : 데이터가 하나 발행됐음을 알리는 이벤트 연속된 데이터의 경우, 데이터가 하나씩 차례대로 onNext() 로 발행된다.
- onComplete() : 단 한번만 발생하며, 데이터 발행이 끝났음을 알리는 완료 이벤트를 Observer에 전달하여 OnNext()를 더 호출하지 않음을 나타낸다.
- onError() : Observable에서 오류가 발생했음을 알리는 이벤트. null은 발행하지 못한다. onError 이벤트가 발생하면 이후에 onNext 및 onComplete 이벤트가 발생하지 않는다
** Observable은 항상 onComplete() 혹은 onError() 둘 중 하나로만 데이터 발행이 종료되어야 한다.

**create()사용시 주의점
- Observable이 dispose될 대 콜백 해지(memory leak)
- 구독하는 동안에만 onNext, onComplete 호출
- 에러는 오직 onError에서만
- BackPressure는 직접 처리
fromXXX() 특정 타입의 데이터를 Observable로 바꿔주는 메소드이다

3-1. fromArray() 배열에 들어있는 데이터를 처리할때사용한다.
```
Integer [] array = {1, 2, 3, 4, 5}
Observable.fromArray(array)
.subscribe(System.out::println)
```
3-2. fromCallable() Callable 을 Observable 로 변환하여 비동기적으로 아이템을 발행할 수 있다.
```
fun main() {
    val callable: Callable<String> = Callable<String> { "Hello" }
    val source: Observable<String> = Observable.fromCallable(callable)
    source.subscribe(System.out::println)
}
```
3-3. fromFuture() Future 객체에서 fromFuture() 함수를 사용해 Observable를 생성 Future 인터페이스를 지원하는 모든 객체를 Observable Source 로 변환하고, Future.get() 메소드를 통해 호출한 값을 반환
```
Future<String> future = Executors.newSingleThreadExecutor().submit(() -> {
    Thread.sleep(1000)
		return "Hello Future" 
})

source: Observable<String> = Observable.fromFuture(future)
source.subscribe { it -> println(it) }
```
Interval() 시간 간격을 두고 데이터를 방출하는 Observable 생성