Có thể quan sát có điều kiện với forkJoin

Một cách dễ dàng nhất mà bạn có thể thêm một câm Observable.of(null)với nullgiá trị nếu tình trạng này không được đáp ứng để giữ nguyên trật tự của phản ứng:

if (this.task.associatedChatThreadId) {
    observables.push(this.messageHubService....);
} else {
    observables.push(Observable.of(null))
}

Sau đó, trong đăng ký, bạn có thể kiểm tra xem chatThread === nullnó có luôn hiện diện ở vị trí cũ hay không.

Ngoài ra, bạn có thể bao bọc mỗi Observable observablesvới một số đối tượng bổ sung sẽ làm cho nó có thể nhận dạng duy nhất trong người đăng ký nhưng điều đó sẽ phức tạp không cần thiết vì vậy cá nhân tôi sẽ bám vào tùy chọn đầu tiên.

Một cách tiếp cận khác là không sử dụng FolkJoin mà đăng ký riêng lẻ. Đồng thời, tạo isPageLoading a BehaviorSubject để đếm số lượng yêu cầu không đồng bộ mà bạn hiện có. Mỗi khi bạn đưa ra yêu cầu, bạn có thể có isPageLoading.next (1) và isPageLoading.next (-1) khi bạn hoàn thành một yêu cầu.

Bạn có thể tạo một hàm trợ giúp chấp nhận một đối tượng có các khóa chuỗi và các giá trị có thể quan sát được và trả về một đối tượng có thể quan sát sẽ phát ra một đối tượng có các khóa tương tự, nhưng có các giá trị kết quả thay vì các giá trị có thể quan sát được.

Tôi thực sự sẽ không nói rằng đây là một phiên bản sạch hơn so với việc sử dụng (null) như martin đề xuất, nhưng nó có thể là một sự thay thế.

function namedForkJoin(map: {[key: string]: Observable<any>}): Observable<{[key: string]: any}> {
    // Get object keys
    const keys = Object.keys(map);

    // If our observable map is empty, we want to return an empty object
    if (keys.length === 0) {
        return of({});
    }


    // Create a fork join operation out of the available observables
    const forkJoin$ = Observable.forkJoin(...keys.map(key => map[key]))

    return forkJoin$
        .map(array => {
            const result = {};
            for (let index = 0; index < keys.length; index++) {
                result[keys[index]] = array[index];
            }

        }));
}

Xin lưu ý rằng tôi không có góc hoặc rxjs nào chạy ở đây vào lúc này, vì vậy tôi không thể xác minh chức năng thực sự hoạt động. Nhưng ý tưởng là: 1. Lấy chìa khóa từ bản đồ đầu vào. 2. Sử dụng các phím để lấy một mảng các vật có thể quan sát và chuyển nó đến tham gia fork. 3. Thêm một hàm ánh xạ để chuyển đổi mảng kết quả trở lại thành một đối tượng.