RxJS 6多Observable订阅问题：do报错及tap无输出求助

你遇到的核心问题是RxJS 6之后操作符的调用方式发生了根本性变化——从原型链操作符改成了pipeable操作符，这也是替换do为tap后没有输出的关键原因。下面我会一步步帮你修正代码：

第一步：修正API调用方法rxLoginPOST #

RxJS 6中，fromPromise被简化为from，并且错误捕获需要用catchError放到pipe中：

import { Observable, from } from 'rxjs';
import { catchError } from 'rxjs/operators';

rxLoginPOST(url, params) {
  return from(somePromise).pipe(
    catchError(handleErrFunction)
  );
}

第二步：重构login方法的操作符调用逻辑 #

RxJS 6不再支持直接链式调用操作符（比如.flatMap().do()），所有操作符必须包裹在.pipe()中，同时注意：

• do改名为tap，仅用于执行副作用（日志、状态更新等），不要在tap里返回Observable，这不会影响流的内容
• Rx.Observable.combineLatest改为直接调用combineLatest函数
• flatMap是mergeMap的别名，两者都可用，推荐用mergeMap更直观

修正后的login方法：

import { Observable, combineLatest, of } from 'rxjs';
import { mergeMap, tap } from 'rxjs/operators';

login(email, password) {
  return APIService.shared.rxLoginPOST('users/signin', { email, password }).pipe(
    mergeMap((response) => {
      if (response.status === 200) {
        // 直接调用combineLatest，不再挂载在Observable上
        return combineLatest(myObservable1, myObservable2, myObservable3);
      } else {
        return of(response);
      }
    }),
    tap((result) => {
      // tap只做副作用操作，比如打印日志、执行无关流的逻辑
      console.log('check 4');
      if (result.length > 0) {
        // 这里写你的副作用逻辑，比如更新状态、打印信息
        // 注意：不要返回Observable，tap不会处理返回值
      }
    }),
    mergeMap((result) => {
      if (result.length > 0) {
        return this.checkUserIsRegistered();
      } else {
        return of(result);
      }
    })
  );
}

关键变化解释 #

1. Pipeable操作符的强制使用：RxJS 6为了优化打包体积（tree-shaking），要求所有操作符必须通过.pipe()方法传入，不能像RxJS 5那样直接链式调用.do()、.flatMap()。你之前的代码没有用pipe，导致操作符根本没有被正确执行，所以tap里的console.log没有输出。
2. tap的正确用法：tap是do的替代，但它的作用只是执行副作用，不会修改或返回Observable流。你原来在do里返回Rx.Observable.of(result)是无效的，这类逻辑如果需要修改流，应该用map或mergeMap。
3. Observable创建函数的导入方式：combineLatest、of、from这些创建Observable的方法现在是独立的函数，需要直接从rxjs导入，不再通过Rx.Observable.xxx调用。

最后验证订阅逻辑 #

你的订阅代码可以保持不变，但确保login方法返回的是正确的Observable：

login(userEmail, userPassword).subscribe(
  (response) => {
    console.log(response);
    if (response === 'something') {
      // some actions
    } else {
      // some actions
    }
  },
  (error) => {
    // some error actions
  }
);

内容的提问来源于stack exchange，提问作者Morton