본문 바로가기
반응형

Development/Reactive5

스케줄러 스케줄러: 스케줄러는 스레드를 지정할 수 있게 해준다. 스케줄러를 활용한 비동기 프로그래밍의 핵심은 데이터 흐름이 발생하는 스레드와 처리된 결과를 구독자에게 전달하는 스레드를 분리 할 수 있다.: subsribeOn()함수는 구독자가 Observable에 subscribe()함수를 호출하여 구독할 때 실행되는 스레드를 지정한다.Observable에서 구독자가 subscribe()함수를 호출했을 때 데이터 흐름을 발행하는 스레드를 지정.한번 호출했을때 결정한 스레드를 고정하며 이후에는 다시 호출해도 스레드가 바뀌지 않는다.: observeOn()함수는 Observable에서 생성한 데이터 흐름이 여기저기 함수를 거치며 처리될 때 동작이 어느 스레드에서 일어나는지 지정할 수 있다.처리된 결과를 구독자에게 전.. 2018. 7. 28.
리액티브 연산자2 리액티브 연산자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.. 2018. 7. 28.
리액티브 연산자1 리액티브 연산자1리액티브 연산자는 부수효과가 없는 순수함수이다. 1. 리액티브 연산자 분류: 생성 연산자- Observable, Single 클래스 등으로 데이터의 흐름을 만들어내는 함수이다.create(), just(), fromArray(), interval(), range(), timer(), defer() 등: 변환 연산자- 어떤 입력을 받아서 원하는 출력 결과를 내는 함수이다. map(), flatMap()등: 필터 연산자- 입력 데이터 중에서 원하는 데이머나 걸러내는 함수이다.filter(), first(), take()등: 합성 연산자- 생성, 변환, 필터 연산자가 주로 단일 Observable을 다룬다면 합성 연산자는 여러 Observable을 조합하는 역할을 하는 함수이다. : 오류 처리.. 2018. 7. 28.
Observable 알고가기 Observable 알고가기 1.Observable이란?: 데이터 흐름에 맞게 알림을 보내 구독자가 데이터를 처리 할 수 있도록 한다.: RxJava1.x에서는 Observable과 Single클래스로 구성: RxJava2.x에서는 Observable, Single, Maybe, Flowable로 클래스를 구분: Maybe클래스는 reduce()함수나 firstElement()함수와 같이 데이터가 발행 될 수 있거나 혹은 발행되지 않고도 완료되는 경우를 의미: Flowable클래스는 Observable에서 데이터가 발행되는 속도가 구독자가 처리하는 속도보다 현저하게 빠른 경우 배압이슈에 대응하는 기능을 추가로 제공한다.- onNext : Observable이 데이터의 발행을 알린다.- onComplete.. 2018. 7. 25.
반응형