[Sunday Study] RxJava

투덜투덜 불평하기에 시간은 짧고 아깝다.

RxJava 

- just()

- create()

- fromArray()

- fromIterator()

- fromCallable() <- 비동기 관련

  (Java 비동기 처리 Callable 스레드)

- fromFuture()

기본 연산자 map(), flatMap(), filter(), reduce()

- map() --- 입력값을 어떤 함수에 넣어서 원하는 값으로 변환하는 함수

- flatMap() --- map() 의 발전형, map() 이 '입력-결과' 가 1:1 함수이지만 flatMap() 은 리턴값이 Observable 이다. 1:N 형태

- reduce() --- 발행한 값을 모두 사용해서 최종 결과 값을 합성할 때 사용.

- Function<T, R> 반환값이 있는 제네릭 함수형 인터페이스 (T 입력값, R 반환값)

- Pair<T, U> 객체는 Apache Commons Lang3 라이브러리에서 제공

RxJava 구구단

int dan = 3;

Function<Integer, Observable<String>> gugudan = num -> 

Observable.range(1,9).map(row -> num + " * " + row + " = " + dan * row);

Observable<String> source = Observable.just(dan).flatMap(gugudan);

source.subscribe(System.out::println);

Reactive Extention: http://reactivex.io/