본문 바로가기

Language/Rx

(6)
[RxKotlin] ReactiveX #6 - 디버깅 / 예외처리 ReactiveX #6 - 디버깅 / 예외처리 RxKotlin 이전 글 ReactiveX #1 - 'ReactiveX 란?' ReactiveX #2 - Observable ReactiveX #3 - Subject ReactiveX #4 - 연산자 'Operator' ReactiveX #5 - Scheduler '병렬처리' INDEX 디버깅(Debugging) doOnXXX() 예외 처리 디버깅 RxJava / RxKotlin은 try-catch문을 사용할 수 없고 로그를 넣을 수 있는 공간이 없기 때문에 doOnXXX() 계열의 함수를 이용하여 강제로 부수 효과를 일으켜 디버깅(Debugging) 처리 doOnXXX() 강제로 부수효과를 일으켜 버그를 알 수 있게 하는 함수들 (중간 연산자) doOnNe..
[RxKotlin] ReactiveX #5 - Scheduler '병렬처리' ReactiveX #5 - Scheduler '병렬처리' RxKotlin 이전 글 ReactiveX #1 - 'ReactiveX 란?' ReactiveX #2 - Observable ReactiveX #3 - Subject ReactiveX #4 - 연산자 'Operator' INDEX Scheduler ? Schedulers : io, computation, single, newThread, trampoline, from Scheduler 지정 : subscribeOn(), observeOn() 우선순위 : subscribeOn / observeOn Scheduler '스케쥴러' Observable은 기본적으로 호출하는 Thread에서 동작 : subscribe{ ... } 블럭에서 모든 데이터를 수신..
[RxKotlin] ReactiveX #4 - 연산자 'Operator' ReactiveX #4 - 연산자 'Operator' RxKotlin 이전 글 ReactiveX #1 - 'ReactiveX 란?' ReactiveX #2 - Observable ReactiveX #3 - Subject 연산자 'Operator' RxKotlin에도 Collection과 유사한 연산자들이 존재 가장 친숙한 연산자인 filter 또는 map을 비롯하여 다양한 연산자를 제공 Collection 연산자와 차이점 입력 - Observable 또는 flowable 출력 - Observable 또는 flowable 생성 연산자 : create, interval, timer, range, fromXXX 등 변환 연산자 : filter, map, concatMap, flatMap, switchMap, ..
[RxKotlin] ReactivX #3 - Subject ReactivX #3 - Subject RxKotlin 이전 글 ReactiveX #1 - 'ReactiveX 란?' ReactiveX #2 - Observable Subject publish() 처럼 Cold Observable -> Hot Observable 변환하는 클래스 Subject는 Observable + Observer (Observable이면서Observer의 역할을 수행) Observer 역할 - 다른 Observable에게 구독하여 item 수신 Observable 역할 - Observable에게 수신받은 item 재배출 또는 새로운 item 배출 Subject의 4가지 종류 PublishSubject, BehaviorSubject, AsyncSubject, ReplaySubject 각..
[RxKotlin] ReactiveX #2 - Observable ReactiveX #2 - Observable (구독 대상자) RxKotlin 이전 글 ReactiveX #1 - 'ReactiveX 란?' INDEX Observable Observable 주요 이벤트 (Callback) : onSubscribe(), onNext(), onError(), onComplete() Observable 생성 : 생성 - create(), just(), range(), empty(), interval(), timer(), fromXXX() Observable 구독 (subscribe) Observable 구독해지 (dispose) Hot & Cold Observable Observable Observable은 Observer 또는 Consumer가 소비하는 값을 생성하는 구독..
[RxKotlin] ReactiveX #1 - 'ReactiveX 란?' RxKotlin - Reactive X Rx(ReactiveX) 란? Reactive Program은 옵저버 패턴으로 구독자에게 변경사항을 알려주는 '비동기 이벤트 기반 프로그래밍' Observer 패턴 + Iterator 패턴 + Functional 프로그래밍 Reactvie (비동기 이벤트 방식) X (이벤트 처리 방식) 필요에 의해 Data 요청(Get) -> Data 가공이 아닌, 데이터 관리주체(Observable)에 데이터 변경시 요청을 받겠다는 구독신청을 하고, 변경사항(event) 발생 시 전달받는 방식 -> Reactive Programming)은 하나의 값을 반환하기 보다 Data Stream을 반환 Reactive (반응형) 프로그래밍과 Functional (함수형) 프로그래밍의 조합..