Observable Pipeline

RxJS 스트림 읽기

RxJS 코드는 데이터가 어디서 시작해 어떤 연산자를 거쳐 언제 구독되는지 흐름으로 읽으면 타입과 비동기 동작을 함께 이해할 수 있습니다.

Source이벤트/요청
Pipemap/filter
ErrorcatchError
Subscribe결과 처리
01

Observable

시간에 따라 여러 값을 낼 수 있는 비동기 데이터 흐름입니다.

02

Observer

next, error, complete 콜백으로 스트림의 신호를 받습니다.

03

Operator

pipe 안에서 값 변환, 필터링, 결합, 에러 처리를 선언합니다.

04

Subscription

구독은 실행의 시작점이며 필요 없을 때 해제해야 합니다.

Promise와 구분

  • Promise는 보통 한 번의 결과, Observable은 여러 번의 값을 다룰 수 있습니다.
  • Observable은 구독 전까지 실행되지 않는 lazy 특성을 가집니다.
  • 타입은 Observable<User[]>처럼 흐르는 값의 형태를 명시합니다.

연산자 감각

map값 변환
filter조건 통과
mergeMap비동기 펼침
catchError오류 회복