angular - 可观察的forkJoin不触发

我正在尝试在两个Observables上使用forkJoin。其中之一以流的形式开始...如果我直接订阅它们，则会收到响应，但forkJoin并未触发。有任何想法吗？

private data$: Observable<any[]>;
private statuses$: Observable<any[]>;
private queryStream = new Subject<string>();

....

this.data$ = this.queryStream
    .startWith('')
     .flatMap(queryInput => {
            this.query = queryInput
            return this._companyService.getCompanies(this.queryRequired + ' ' + this.query, this.page, this.sort);
                })
            .share();

...

Observable.forkJoin(this.statuses$, this.companies$)
            .subscribe(res => {
                console.log('forkjoin');
                this._countStatus(res[0], res[1]);
            });


// This shows arrays in the console...

this.statuses$.subscribe(res => console.log(res));
this.companies$.subscribe(res => console.log(res));

// In the console
Array[9]
Array[6]

最佳答案

forkJoin的一个非常常见的问题是，它要求所有源Observable都发出至少一项，并且所有它们都必须完成。

换句话说，如果this.statuses$或this.companies$不发出任何项目，并且直到它们都完成，forkJoin才不发出任何东西。

this.statuses$.subscribe(
    res => console.log(res),
    undefined,
    () => console.log('completed'),
);

关于angular - 可观察的forkJoin不触发，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/42809658/