Hành vi Promise.all với RxJS Observables?

Question

Trong Angular 1.x đôi khi tôi cần phải thực hiện nhiều yêu cầu http và làm điều gì đó với tất cả các phản hồi. Tôi sẽ ném tất cả các lời hứa trong một mảng và gọi Promise.all(promises).then(function (results) {...}).

Thực tiễn tốt nhất về góc 2 dường như chỉ hướng tới việc sử dụng sốcủa RxJS làm thay thế cho lời hứa trong yêu cầu http. Nếu tôi có hai hoặc nhiều Đài quan sát khác nhau được tạo từ yêu cầu http, chúng có tương đương với Promise.all() không?

Answer 1

Cách khác đơn giản hơn để bắt chước Promise.all là sử dụng các nhà điều hành forkJoin (nó bắt đầu tất cả các quan sát song song và tham gia các yếu tố cuối cùng của họ):

• documentation
• liên kết liên quan: Cf. RxJS: concat three promises, distinguish results

Một chút ngoài phạm vi, nhưng trong trường hợp có lời hứa chuỗi, bạn có thể sử dụng đơn giản flatMap: Cf. RxJS Promise Composition (passing data)

Answer 2

forkTính năng cũng hoạt động tốt, nhưng tôi thích combineLatest vì bạn không cần phải lo lắng về việc sử dụng giá trị cuối cùng của các quan sát được. Bằng cách này, bạn chỉ có thể được cập nhật bất cứ khi nào có bất kỳ giá trị nào trong số đó phát ra một giá trị mới (ví dụ: bạn tìm nạp một khoảng thời gian hoặc một thứ gì đó).

Answer 3

On reactivex.ioforkJoin thực sự chỉ đến Zip, mà đã làm công việc cho tôi:

let subscription = Observable.zip(obs1, obs2, ...).subscribe(...);