JEP's Diary

스케줄러: 스케줄러는 스레드를 지정할 수 있게 해준다. 스케줄러를 활용한 비동기 프로그래밍의 핵심은 데이터 흐름이 발생하는 스레드와 처리된 결과를 구독자에게 전달하는 스레드를 분리 할 수 있다.: subsribeOn()함수는 구독자가 Observable에 subscribe()함수를 호출하여 구독할 때 실행되는 스레드를 지정한다.Observable에서 구독자가 subscribe()함수를 호출했을 때 데이터 흐름을 발행하는 스레드를 지정.한번 호출했을때 결정한 스레드를 고정하며 이후에는 다시 호출해도 스레드가 바뀌지 않는다.: observeOn()함수는 Observable에서 생성한 데이터 흐름이 여기저기 함수를 거치며 처리될 때 동작이 어느 스레드에서 일어나는지 지정할 수 있다.처리된 결과를 구독자에게 전..

리액티브 연산자2 생성연산자는 Observable로 데이터 흐름을 만들고 변환 연산자와 필터 연산자는 데이터 흐름을 내가 원하는 방식으로 변형한다.: 생성 연산자 just(), fromXXX(), create(), interval(), ranger(), timer(), intervalRange(), defer(), repeat(): 변환 연산자map(), flatMap(), concatMap(), switchMap(), groupBy(), scan(), buffer(), window(): 필터 연산자filter(), take(), skip(), distinct(): 결합 연산자zip(), combineLastest(), merge(), concat(): 조건 연산자amb(), takeUntil(), sk..

리액티브 연산자1리액티브 연산자는 부수효과가 없는 순수함수이다. 1. 리액티브 연산자 분류: 생성 연산자- Observable, Single 클래스 등으로 데이터의 흐름을 만들어내는 함수이다.create(), just(), fromArray(), interval(), range(), timer(), defer() 등: 변환 연산자- 어떤 입력을 받아서 원하는 출력 결과를 내는 함수이다. map(), flatMap()등: 필터 연산자- 입력 데이터 중에서 원하는 데이머나 걸러내는 함수이다.filter(), first(), take()등: 합성 연산자- 생성, 변환, 필터 연산자가 주로 단일 Observable을 다룬다면 합성 연산자는 여러 Observable을 조합하는 역할을 하는 함수이다. : 오류 처리..

Observable 알고가기 1.Observable이란?: 데이터 흐름에 맞게 알림을 보내 구독자가 데이터를 처리 할 수 있도록 한다.: RxJava1.x에서는 Observable과 Single클래스로 구성: RxJava2.x에서는 Observable, Single, Maybe, Flowable로 클래스를 구분: Maybe클래스는 reduce()함수나 firstElement()함수와 같이 데이터가 발행 될 수 있거나 혹은 발행되지 않고도 완료되는 경우를 의미: Flowable클래스는 Observable에서 데이터가 발행되는 속도가 구독자가 처리하는 속도보다 현저하게 빠른 경우 배압이슈에 대응하는 기능을 추가로 제공한다.- onNext : Observable이 데이터의 발행을 알린다.- onComplete..

0. 리액티브 프로그래밍 목적 - 서버 다수와 통신하게 되면 API 호출 각가에 콜백을 추가하게 되고 콜백이 늘어날수록 코드복잡성도 늘어난다. 이를 콜백지옥이라 한다. RxJava는 이러한 콜백지옥을 해결하는 방법이 된다.- 복잡한 비동기 프로그램을 쉽게 만들 수 있게 도와준다. 이벤트(스크린터치, 마우스클릭, 키입력, 서버의 비동기응답)에 소비자가 비동기로 반응하여 처리한다.- 또한 비동기에서 처리하기 힘든 에러 처리나 데이터 가공을 쉽게 도와준다. 이벤트를 콜백이 아닌 데이터의 모음으로 모델링하기 때문이다. 1.리액티브 프로그래밍: 데이터 흐름과 전달에 관한 프로그래밍 패러다임.: 데이터 흐름을 먼저 정의하고 데이터가 변경되었을때 연관되는 함수나 수식이 업데이트되는 방식- 예 ) 엑셀에서의 1~12월..