RxJS等待可观察对象，然后创建另一个可观察对象，依此类推

import { of } from 'rxjs';
import { concatMap, delay } from 'rxjs/operators';

// 假设有一个返回Promise的异步函数
function asyncFunction(value) {
  return new Promise(resolve => {
    setTimeout(() => {
      resolve(value);
    }, 1000);
  });
}

// 创建一个可观察对象
const source$ = of(1, 2, 3);

// 使用concatMap操作符等待可观察对象完成，并创建另一个可观察对象
const result$ = source$.pipe(
  concatMap(value => asyncFunction(value).pipe(delay(1000)))
);

// 订阅结果可观察对象
result$.subscribe(value => {
  console.log(value);
});