RxJs forkJoin几个连续的观察量

RxJs forkJoin 基础概念

forkJoin 是 RxJs 中的一个操作符，用于并行地订阅多个 Observable，并在所有 Observable 都完成时，将它们的最后一个值组合成一个数组返回。这个操作符类似于 JavaScript 的 Promise.all，但它是专门为异步流设计的。

优势

并行执行：forkJoin 允许你并行地执行多个异步操作，而不是顺序执行，从而提高性能。
结果组合：当所有 Observable 完成时，forkJoin 会将它们的结果组合成一个数组，便于后续处理。
错误处理：如果任何一个 Observable 发生错误，forkJoin 会立即终止并抛出该错误。

类型

forkJoin 接受一个 Observable 数组作为参数，并返回一个新的 Observable。

应用场景

并行数据获取：当你需要从多个 API 端点获取数据时，可以使用 forkJoin 来并行执行这些请求。
并行计算：当有多个独立的计算任务需要执行时，可以使用 forkJoin 来并行处理这些任务。

示例代码

以下是一个使用 forkJoin 的示例，展示了如何并行获取两个 API 的数据：

import { forkJoin, of } from 'rxjs';
import { ajax } from 'rxjs/ajax';

const request1 = ajax.getJSON('https://api.example.com/data1');
const request2 = ajax.getJSON('https://api.example.com/data2');

forkJoin([request1, request2]).subscribe({
  next: ([data1, data2]) => {
    console.log('Data from API 1:', data1);
    console.log('Data from API 2:', data2);
  },
  error: err => console.error('Error:', err),
  complete: () => console.log('All requests completed')
});

常见问题及解决方法

问题：为什么 `forkJoin` 没有按预期工作？

原因：

Observable 没有完成：如果任何一个 Observable 没有完成（例如，被取消订阅或发生错误），forkJoin 将不会返回结果。
Observable 数组为空：如果传递给 forkJoin 的 Observable 数组为空，它将立即完成并返回一个空数组。

解决方法：

确保所有 Observable 都能正常完成。
在使用 forkJoin 之前，检查 Observable 数组是否为空。

import { forkJoin, of } from 'rxjs';
import { ajax } from 'rxjs/ajax';

const request1 = ajax.getJSON('https://api.example.com/data1');
const request2 = ajax.getJSON('https://api.example.com/data2');

if (request1 && request2) {
  forkJoin([request1, request2]).subscribe({
    next: ([data1, data2]) => {
      console.log('Data from API 1:', data1);
      console.log('Data from API 2:', data2);
    },
    error: err => console.error('Error:', err),
    complete: () => console.log('All requests completed')
  });
} else {
  console.error('No requests to perform');
}