switchMap과 forkJoin의 차이는 무엇인가요?

Q1: switchMap이란 무엇인가요?
A1: switchMap은 RxJS 연산자로, 소스 Observable이 발행하는 값마다 새로운 내부 Observable을 생성하고 구독합니다. 이전에 생성된 내부 Observable이 아직 완료되지 않았다면 구독을 취소(switch)하고, 새로 생성된 내부 Observable의 값을 방출합니다. 주로 최신 요청의 결과만 필요할 때 사용됩니다.

Q2: forkJoin이란 무엇인가요?
A2: forkJoin은 RxJS 연산자로, 여러 Observable을 병렬로 동시에 구독하고, 모든 Observable이 완료되었을 때 각각의 마지막 값을 배열이나 객체 형태로 합쳐서 방출합니다. 모든 Observable이 완료되어야 결과가 나오기 때문에 주로 여러 비동기 작업의 최종 결과를 한번에 받고 싶을 때 사용됩니다.

Q3: switchMap과 forkJoin의 가장 큰 차이점은 무엇인가요?
A3:
- switchMap은 소스 Observable에서 발생하는 각 값을 기준으로 내부 Observable을 생성하며, 이전 내부 Observable 구독을 취소하고 최신 값에 집중합니다.
- forkJoin은 병렬로 여러 Observable을 동시에 실행하고, 모든 Observable이 완료된 후 각각의 마지막 결과들을 한 번에 방출합니다.

Q4: switchMap은 언제 사용하는 것이 적합한가요?
A4: 사용자가 입력하는 검색어에 따른 API 호출처럼 빠르게 변하는 이벤트에서 최신 데이터만 필요할 때, 이전 요청을 취소하고 새로운 요청만 처리하고자 할 때 적합합니다.
Q5: forkJoin은 언제 사용하는 것이 적합한가요?
A5: 서로 독립적인 여러 비동기 요청이 모두 완료되어야 다음 작업을 진행하거나, 모든 결과를 한번에 받아 처리해야 할 때 적합합니다.

Q6: switchMap은 내부 Observable을 취소하는데 forkJoin은 취소하나요?
A6: switchMap은 새로운 값이 들어오면 이전 내부 Observable의 구독을 취소(switch)하지만, forkJoin은 구독된 모든 Observable이 완료될 때까지 기다리며 자동 취소 기능은 없습니다.

Q7: switchMap과 forkJoin을 함께 사용할 수 있나요?
A7: 네, 가능하며 상황에 따라 switchMap 내에서 여러 Observable의 최종 결과를 forkJoin으로 모아 처리하는 등의 조합도 자주 사용됩니다.

요약
- switchMap : 순차적 내비게이션, 최신 데이터 우선, 이전 구독 취소
- forkJoin : 병렬 전체 완성 대기, 모든 Observable 마지막 값 결합, 취소 없음

이 두 연산자는 목적과 처리 방식이 달라 상황에 맞게 선택해서 사용해야 합니다.

switchMap과 forkJoin은 모두 RxJS에서 사용되는 연산자이지만, 목적과 동작 방식이 크게 다릅니다.

각각의 차이를 이해하려면, 이들이 Observable 스트림을 처리하는 방식과 결과를 반환하는 방법에 주목해야 합니다.

1. 기본 개념과 역할 - switchMap: 주로 한 Observable에서 방출되는 값마다 새로운 내부 Observable을 생성하고, 이전에 생성된 내부 Observable이 완료되지 않았더라도 그것을 취소(구독 해지)하고 새로 생성된 Observable에 구독을 전환(switch)합니다.

즉, 최신 Observable의 결과만을 반영합니다.

- forkJoin: 여러 Observable을 병렬로 동시에 실행한 후, 모든 Observable이 완료되었을 때 각 Observable이 마지막으로 방출한 값을 모아서 배열 또는 객체 형태로 반환하는 연산자입니다.

모든 Observable이 완료되어야 결과가 나옵니다.



2. 실행 시점 및 구독 관리 - switchMap: - 내부 Observable이 생성될 때마다 이전 Observable 구독을 즉시 취소합니다.

- 주로 사용자의 연속된 입력이나 빠르게 바뀌는 이벤트에 대해 이전 요청을 무시하고 최신 요청만 처리할 때 유용합니다.

- forkJoin: - 참여하는 모든 Observable을 동시에 구독합니다.

- 모든 Observable이 완료될 때까지 대기하며, 어떤 Observable이 실패 하면 전체가 실패합니다.

- 주로 여러 비동기 작업을 병렬 처리하고, 모두 완료된 결과를 한 번에 받고 싶을 때 사용합니다.



3. 결과물의 형태 및 시점 - switchMap: - 내부 Observable의 결과를 처리하면서 즉시 방출합니다.

- 이전에 생성된 Observable의 결과는 무시하거나 중단되므로, 항상 최신값(마지막으로 switch한 Observable)만 배열하지 않고 개별적으로 방출합니다.

- forkJoin: - 모든 Observable의 마지막 값들을 모두 수집하여 배열(혹은 키별 객체) 형태로 한 번에 내보냅니다.

- 결괏값은 각 Observable이 완료되어야만 방출됩니다.



4. 사용 사례 예시 - switchMap: - 사용자 검색어 변경 시 매번 API 호출하는데, 이전 호출 완료 전에 새 검색어가 들어오면 이전 호출을 취소하고 새 호출만 처리하고자 할 때. - 실시간으로 이벤트를 변형하거나 최신 데이터를 처리할 때. - forkJoin: - 여러 API를 병렬로 호출해 각각의 결과를 모두 받아서 한꺼번에 처리하는 경우. - 예를 들어, 사용자 프로필 정보, 설정, 선호 데이터를 동시에 불러와서 UI에 한번에 반영하고자 할 때. switchMap은 한 스트림 내에서 변하는 값을 기반으로 내부 스트림을 전환하며 이전 스트림을 취소하는 반면, forkJoin은 여러 스트림을 병렬로 실행하며 모두 완료된 후 종합적인 결과를 반환하는 차이가 있습니다.

따라서 또렷한 사용 목적과 데이터 흐름 모델에 따라 적절한 연산자를 선택하는 것이 중요합니다.