Lucky Dog

Operator 자바 관점에서는 메서드. 순수함수(Pure functions) 생성, 변환, 필터, 합성, 오류처리, 유틸리티, 조건, 수학과집합형, 배압 등이 있다. map 입력 값을 어떠한 함수에 넣어서 원하는 값을 반환하는 함수 String[] balls = {"1", "2", "3", "4", "5"}; // First way Observable source = Observable.fromArray(balls) .map(ball -> ball + ""); // Second way // Function getDiamond = ball -> ball + ""; // Observable source = Observable.fromArray(balls).map(getDiamond); source.subs..

RxJava - 데이터 발행자 (Data source) Observable class 옵서버 패턴을 구현. 데이터 흐름에 맞게 알림을 보내 구독자가 데이터를 처리할 수 있도록 한다. 데이터를 무한하게 발행 할 수 있다. 세 가지 알림을 구독자에게 전달 onNext : Observable이 데이터의 발생을 알림. onComplete : 모든 데이터 발행 완료 알림. 이후 onNext 발생 안함. onError : 에러 발생. onError 이벤트 후에 onNext 및 onComplete 발생안함. Observable source = Observable.just(1, 2, 3, 4, 5); source.subscribe(System.out::println);Cold Observable vs Hot Obser..

Scheduler 데이터를 처리하고자 하는 특정한 스레드 Scheduler 용도 Schedulers.computation( ) 이벤트-루프와 콜백 처리 같은 연산 중심적인 작업을 위해 사용된다. 그렇기 때문에 I/O를 위한 용도로는 사용하지 말아야 한다(대신 Schedulers.io( )를 사용) 기본적으로 스레드의 수는 프로세서의 수와 같다 Schedulers.io( ) 블러킹 I/O의 비동기 연산 같은 I/O 바운드 작업을 처리한다. 이 스케줄러는 필요한 만큼 증가하는 스레드-풀을 통해 실행된다; 일반적인 연산이 필요한 작업은 Schedulers.computation( )를 사용하면 된다 Schedulers.newThread( ) 각각의 단위 작업을 위한 새로운 스레드를 생성한다 AndroidSche..

RxJava Java 로 Reactive Programming 을 구현하기 위한 라이브러리 구성요소 Observable Observer Operator Observable 데이터 제공자. 지속적으로 흐름을 파악할 수 있는 데이터. Ex) 현실에서 유튜버를 Observable 하다 라고 할 수 있고, 유튜버를 구독하는 사람들을 구독자(Subscriber) 라고 할 수 있다. Observable 의 두 가지 종류 Hot Observable 구독자(Subscriber) 가 없어도 동작 (클릭 이벤트, 센서 이벤트 등) Cold Observable 구독자(Subscriber) 가 있을 때만 동작 (웹 요청, DB쿼리 등) Observable 예시 just 를 통해 1, 2, 3, 4 를 Emit(방출) 하는 O..

fromArray Array 의 값을 Observable 형태로 변환 Integer[] arr = new Integer[]{ 1, 2, 3, 4, 5 }; Observable observable = Observable.fromArray(arr);map 입력 값을 어떠한 함수에 넣어서 원하는 값을 반환하는 함수 Integer[] arr = new Integer[]{ 1, 2, 3, 4, 5 }; Observable.fromArray(arr).map((Function) integer -> integer + 10) .subscribe(new DisposableObserver() { @Override public void onNext(Object o) { Log.d("TAG", "Object o : " + o)..

1. 반응형 프로그래밍 (Reactive Programming) > 비동기 데이터 스트림을 사용한 프로그래밍.OOP (Object Oriented Programming) 와 같이 하나의 '개발 패러다임' 이다. 2. Rx (Reactive Extension, ReactiveX) > 반응형 프로그래밍 개발을 위한 라이브러리. Ex) RxJava, RxJs, RxSwift, RxKotlin, RxAndroid, RxCpp 등이 있다. 참조 : http://reactivex.io/languages.html 3. RxJava2 > 자바에서 반응형 프로그래밍 개발을 위한 라이브러리. RxJava 와 RxJava2 는 단순히 라이브러리 버전 1.x 와 2.x 차이.특별히 RxJava 1, 2 와 같이 명시하지 않고..