Reactor Operations

🧶 생성

Create

https://reactivex.io/

• Observable 생성

Just

https://reactivex.io/documentation/operators/just.html

• 하나의 item만 방출(emit)하는 observable 생성

From

https://reactivex.io/documentation/operators/from.html

• 다양한 객체와 데이터 유형을 observable로 변환
• e.g. 리스트를 Flux로 변환

Empty

https://reactivex.io/documentation/operators/empty-never-throw.html

• 빈 observable 생성

Defer

https://reactivex.io/documentation/operators/defer.html

• observer가 구독할 때까지 observable을 생성하지 않고, 각 observer에 대해 새로운 observable 생성

🔮 변환

flatMap

https://reactivex.io/

비동기 처리

groupBy

https://reactivex.io/

• Obsevable을 기준에 따라 그룹으로 obsevable 방출

map

https://reactivex.io/

동기 처리

입력과 리턴 값은 Mono<T>

🔊 필터

distinct

• 중복을 없앤 observable 반환

filter

• 조건에 만족하는 항목만 방출

elementAt

https://reactivex.io/

• Flux에서 i번째 요소를 Mono로 반환

ignoreElements

https://reactivex.io/

• Observable의 항목을 내보내지 않고 종료 알림 발생
• Observable을 사용하지 않고 종료할 때 이용
• onNext 핸들러가 호출되지 않는다.

take

https://reactivex.io/

• 앞에서 n개의 요소 방출

🧩 결합

merge

https://reactivex.io/

• 여러 observable을 합쳐서 하나의 observable 반환

startWith

https://reactivex.io/

• Observable의 항목을 방출하기 전에 지정된 항목을 추가

zip

https://reactivex.io/

• 여러 observable의 방출을 결합하여 하나의 observable로 방출

📍 오류 처리

onErrorResume

https://reactivex.io/

• error 신호 처리

try-catch 문에서 catch와 유사

retry

https://reactivex.io/

• error 신호가 발생하면 다시 실행

🎮 유틸리티

delay

• Observable에서 방출 시점을 특정 시간만큼 앞으로 이동

do

https://reactivex.io/

• 원본 시퀀스에 영향을 주지 않고 처리 로직 추가
• 주로 시퀀스의 신호를 잡아서 사용
• e.g. doOnNext, doOnComplete, doOnError 등

serialize

https://reactivex.io/

• Observable이 직렬화된 호출을 수행하고 올바르게 작동하도록 강제

subscribe

• Observable 방출 및 알림에 따라 작동
• e.g. onNext, onError, onComplete

구독하지 않은 Observable은 처리되지 않는다.

timestamp

https://reactivex.io/

• 각 항목에 타임스탬프 추가

🔎 조건

all

https://reactivex.io/

• Observable이 내보낸 모든 항목이 조건을 만족하는지 여부 반환

contains

https://reactivex.io/

• Observable이 특정 항목을 방출하는지 여부 반환

defaultIfEmpty

https://reactivex.io/

• Observable이 아무것도 방출하지 않을 때 특정 항목 반환

skipWhile

https://reactivex.io/

• 조건을 만족하지 않을 때까지 방출된 항목 무시

takeWhile

https://reactivex.io/

• 조건을 만족하지 않은 후 observable이 내보낸 항목 무시

📝 집계

average

• 뒤에 자료형을 붙여서 사용
• 평균을 Mono로 반환

count

• 조건을 만족하는 item의 개수를 카운팅하여 Mono로 반환

max

• 최댓값

min

• 최솟값

sum

• 합

reduce

https://reactivex.io/

• 시퀀스의 각 item에 함수를 순차적으로 적용하고 최종 값 반환