带forkJoin的条件可观测

最简单的是你可以加一个哑巴 Observable.of(null) null 如果不满足条件以保持相同的响应顺序,则返回值:

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

chatThread === null 因为它总是出现在同一个位置。

或者,您可以将每个可观察到的 observables

另一种方法是不使用folkJoin,而是单独订阅。同时,使isPageLoading成为一个BehaviorSubject,它统计当前有多少异步请求。每次提出请求时,您都可以isPageLoading.next文件(1) ,和isPageLoading.next文件(-1)当您完成请求时。

您可以创建一个helper函数,该函数接受具有字符串键和可观察值的对象,并返回一个可观察值,该对象将发出具有相同键的对象,但具有结果值而不是作为值的可观察值。

我并不是说这是一个比martin建议的使用(null)更干净的版本,但它可能是一个替代方案。

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];
            }

        }));
}

1从输入地图中获取关键点。 2使用这些键获得一个可观察的数组,并将其传递给fork join。 三。添加一个映射函数,将生成的数组转换回对象。