将具有嵌套订阅的方法转换为RxJS管道

import { from, of } from 'rxjs';
import { switchMap, catchError } from 'rxjs/operators';

function nestedSubscribeMethod() {
  asyncOperation1((result1) => {
    asyncOperation2(result1, (result2) => {
      asyncOperation3(result2, (result3) => {
        // 处理最终结果
      });
    });
  });
}

function rxjsPipelineMethod() {
  from(asyncOperation1()).pipe(
    switchMap((result1) => asyncOperation2(result1)),
    switchMap((result2) => asyncOperation3(result2)),
    catchError((error) => {
      // 处理错误
      return of(null);
    })
  ).subscribe((result3) => {
    // 处理最终结果
  });
}