使用RXJS一起返回两个观察值的结果

使用RXJS可以通过使用forkJoin操作符来同时返回两个观察值的结果。

forkJoin操作符接收一个Observable数组作为参数，当所有的Observable都完成时，它会发出一个数组，包含每个Observable发出的最新值。如果其中任何一个Observable发生错误，则forkJoin会立即发出错误。

下面是一个使用forkJoin操作符返回两个观察值结果的示例代码：

import { forkJoin, Observable } from 'rxjs';

// 创建两个模拟的Observable
const observable1: Observable<number> = new Observable(observer => {
  setTimeout(() => {
    observer.next(1);
    observer.complete();
  }, 1000);
});

const observable2: Observable<string> = new Observable(observer => {
  setTimeout(() => {
    observer.next('Hello');
    observer.complete();
  }, 2000);
});

// 使用forkJoin同时订阅两个Observable并获取结果
forkJoin([observable1, observable2]).subscribe(([result1, result2]) => {
  console.log('Result 1:', result1);
  console.log('Result 2:', result2);
});

在上面的示例中，observable1会在1秒后发出值1，observable2会在2秒后发出字符串'Hello'。使用forkJoin操作符订阅这两个Observable，并在它们都完成后获取结果。最终的输出结果将会是：