switchMap의 내부 작동 원리는 무엇인가요?

Q1: switchMap이란 무엇인가요?
A1: switchMap은 RxJS에서 제공하는 고차 연산자로, 옵저버블의 값을 변환하여 새 옵저버블을 방출할 때 사용됩니다. 내부적으로 이전에 생성된 옵저버블을 취소(switch)하고 최신 옵저버블만 구독하여 방출합니다.

Q2: switchMap은 어떻게 동작하나요?
A2: 원본 옵저버블에서 새로운 값이 방출되면, switchMap은 해당 값을 기준으로 내부 함수(프로젝션 함수)를 실행해 새로운 옵저버블을 생성합니다. 이때 이전에 활성화되어 있던 내부 옵저버블 구독을 취소하고, 새롭게 생성된 옵저버블만 구독하여 그 값들을 외부로 방출합니다.

Q3: switchMap이 내부적으로 이전 옵저버블을 취소한다는 것은 무슨 의미인가요?
A3: switchMap은 비동기 작업 중에 새로운 값이 방출되면, 기존 작업(이전 옵저버블)에서 발생하는 결과를 무시하고 구독을 해제(cancellation)합니다. 이는 메모리 누수 방지 및 최신 요청에만 반응하도록 만듭니다.

Q4: switchMap 내부 동작 과정은 어떻게 진행되나요?
A4:
1. 원본 옵저버블에서 값 방출 감지
2. 내부 프로젝션 함수 실행 → 새 옵저버블 생성
3. 기존 내부 옵저버블 구독 해제
4. 새 내부 옵저버블 구독
5. 내부 옵저버블에서 방출되는 값을 외부 옵저버블로 방출
6. 원본 옵저버블 완료 시, 내부 옵저버블 완료 대기 후 전체 완료
Q5: switchMap과 비슷한 연산자와의 차이점은 무엇인가요?
A5:
- concatMap: 내부 옵저버블을 순차적으로 처리, 이전 옵저버블 완료 후 다음 구독
- mergeMap: 내부 옵저버블을 병렬로 모두 구독, 완료 여부와 상관없이 결과 방출
- switchMap: 새 값 감지 시 이전 옵저버블 취소 후 새 구독, 항상 최신 결과만 방출

Q6: switchMap은 어떤 경우에 유용하게 사용되나요?
A6: 검색 입력 자동완성, 실시간 데이터 스트림 등에서 최신 요청만 반응하고 이전 요청 결과는 무시하고자 할 때 유용합니다. 예를 들어, 사용자가 입력을 빠르게 바꿀 때 이전 서버 요청을 취소하고 최신 입력만 처리할 때 적합합니다.

Q7: switchMap 내부에서 프로젝션 함수는 어떤 역할을 하나요?
A7: 원본 옵저버블의 값이 들어올 때마다 호출되어, 해당 값을 기반으로 새로운 옵저버블을 생성하는 역할을 합니다. 이 옵저버블이 switchMap의 결과 스트림에서 방출되는 데이터를 제공합니다.

Q8: switchMap 사용 시 주의해야 할 점은 무엇인가요?
A8: 내부 옵저버블이 완료되지 않는 경우(예: 무한 스트림) 이전 옵저버블이 취소되지 않아 리소스가 해제되지 않을 수 있으니 적절히 관리해야 합니다. 또한, 내부 옵저버블이 에러를 방출하면 전체 스트림이 오류로 종료될 수 있습니다.

---

요약하면, switchMap은 원본 스트림에서 방출된 값마다 새로운 내부 옵저버블을 생성하고 이전 내부 옵저버블 구독을 취소하여 최신 내부 옵저버블의 결과만 방출하는 고차 연산자입니다. 이로써 효율적으로 최신 상태만 반영할 수 있게 하는 것이 내부 작동 원리입니다.

switchMap은 RxJS에서 주로 사용되는 고차 연산자 중 하나로, 주어진 소스 Observable에서 방출된 값을 가지고 내부 Observable을 생성하고, 이 내부 Observable의 방출값을 외부로 내보내는 역할을 합니다.

특히, switchMap의 가장 큰 특징은 새로운 내부 Observable이 생성될 때 이전에 생성된 내부 Observable을 취소(unsubscribe)시킨다는 점입니다.

내부 작동 원리를 단계별로 설명하면 다음과 같습니다: 1. 소스 Observable로부터 값 방출 감지 switchMap은 외부(소스) Observable이 값을 방출할 때마다 트리거됩니다.

예를 들어, 어떤 키 입력이나 HTTP 요청 등의 이벤트 스트림이 소스가 될 수 있습니다.



2. 함수를 통해 내부 Observable 생성 소스 Observable이 값 `x`를 방출하면, switchMap에 전달된 함수가 `x`를 인자로 받아 새로운 내부 Observable을 생성합니다.

이 함수는 보통 Observable을 반환하며, 예를 들어 API 호출을 하는 Observable일 수 있습니다.



3. 이전 내부 Observable 구독 취소 중요한 점은, 새로운 소스 값이 들어와 새로운 내부 Observable이 생성될 때, 이전에 구독하고 있던 내부 Observable에 대한 구독을 자동으로 취소(unsubscribe)합니다.

이렇게 함으로써 마지막으로 생성된 내부 Observable에서 방출되는 값만 처리하게 됩니다.



4. 새로운 내부 Observable 구독 이전 내부 Observable 구독을 취소한 후, 새로 생성된 내부 Observable을 구독하기 시작합니다.

그리고 그 내부 Observable이 방출하는 값을 외부로 그대로 내보냅니다.



5. 결과물로 외부 Observable 생성 결국 switchMap은 소스 Observable의 각 방출값을 다른 Observable로 매핑하고, 단 하나의 최신 Observable만 구독하여 그 내부의 값만 방출하는 새로운 Observable을 반환합니다.

이 동작 방식 덕분에 switchMap은 특히 빠르게 변화하는 이벤트 스트림에서 불필요한 이전 비동기 작업(예: 네트워크 요청)을 취소하고 최신 작업 결과만 처리하고자 할 때 매우 유용합니다.

예를 들어, 사용자가 타이핑할 때마다 API 요청을 보내는 상황에서, 이전 요청이 완료되기 전에 새로운 요청이 시작되면 이전 요청은 취소되어 불필요한 데이터 처리 및 리소스 낭비를 방지할 수 있습니다.

switchMap은 소스 Observable의 각 값으로부터 내부 Observable을 만들고, 가장 최근에 생성된 내부 Observable만 구독하며, 이전의 내부 Observable 구독은 자동으로 취소하는 방식으로 동작합니다.