Sự khác biệt giữa concatMap và mergeMap trong việc duy trì thứ tự xử lý dữ liệu là gì? Khi nào nên ưu tiên sử dụng concatMap?

Question

Accepted Answer

Phân tích cơ chế

mergeMap: Thực thi tất cả các Inner Observable ngay lập tức khi nhận được giá trị từ Source Observable. Nó không đảm bảo thứ tự kết quả trả về khớp với thứ tự dữ liệu đầu vào.
concatMap: Chờ đợi Inner Observable hiện tại hoàn thành (complete) trước khi bắt đầu Inner Observable tiếp theo. Nó đảm bảo tính tuần tự tuyệt đối.

Khi nào sử dụng concatMap?
Nên sử dụng concatMap khi thứ tự thực hiện là bắt buộc, ví dụ: cập nhật trạng thái đơn hàng (Order Status) từ 'Pending' sang 'Processing' rồi sang 'Completed'. Nếu dùng mergeMap, các request có thể đến server không đúng thứ tự, dẫn đến lỗi logic nghiệp vụ.
Ví dụ minh họa
// Đảm bảo các request được xử lý tuần tự
input$.pipe(concatMap(item => saveToDatabase(item))).subscribe();
Lưu ý: concatMap có thể làm tăng độ trễ (latency) của toàn bộ chuỗi nếu một request bị treo.

Sự khác biệt giữa concatMap và mergeMap trong việc duy trì thứ tự xử lý dữ liệu là gì? Khi nào nên ưu tiên sử dụng concatMap?

Phân tích cơ chế

Khi nào sử dụng concatMap?

Làm Chủ Phỏng Vấn & Nâng Cao Trình Độ Chuyên Nghiệp

Tải Tuyển Tập 100+ Câu Hỏi Phỏng Vấn Chuyên Sâu (PDF)

Cần Mentor Phỏng Vấn Thử 1-1 & Tối Ưu CV?

Kiểm Tra CV Chuẩn ATS Miễn Phí

Câu hỏi reactive programming liên quan cùng chủ đề