본문 바로가기

Rx

RxKotlin- Part 8. Reactive 연산자

728x90

Reactive 연산자

 

연산자 종류 연산자 함수
생성(Creating) just(), fromXXX(), create(), interval(), range(), timer(), intervalRange(), defer(), repeat()
옵저버블, 싱글 클래스 등으로 데이터의 흐름을 만들어내는 함수입니다.
변환(Transforming) map(), flatMap(), concatMap(), switchMap(), groupBy(), scan(), buffer(), window(), reduce()
어떤 입력을 받아 원하는 출력 결과를 내는 함수입니다.
필터(Filter) filter(), take(), skip(), distinct()
입력 데이터 중 원하는 데이터만 걸러냅니다.
합성(Combining) zip(), combineLatest(), Merge(), concat()
생성, 변환, 필터 연산자가 단일 옵저버블을 다루는 반면, 합성 연산자는 여러 옵저버블을 조합합니다.
 조건(Conditional) amb(), takeUntil(), skipUntil(), all()
옵저버블의 흐름을 제어하는 역할을 합니다.
오류 처리(Error Handling) onErrorReturn(), onErrorResumeNext(), retry(), retryUntil()
수학 및 기타 count(), max(), min(), sum(), average() / delay(), timeInterval()
유틸리티(Utility) subscribe(), subscribeOn(), observeOn()