如何基于另一个Observable生成内容？如何封装processResult到Observable<bool>？

嘿，我来帮你搞定这两个RxJS相关的问题！

1. 如何基于另一个Observable的内容，生成目标Observable的内容？ #

这在RxJS里是非常常见的场景，核心是用操作符处理源Observable的输出，进而生成新的Observable。根据需求不同，常用的操作符有这些：

• map：同步转换值
  如果只是需要把源Observable输出的每个值转换成另一种格式/类型，直接用map就够了。比如把数字转换成对应描述字符串：

  import { of } from 'rxjs';
  import { map } from 'rxjs/operators';
  
  const sourceNumbers$ = of(1, 2, 3);
  const targetStrings$ = sourceNumbers$.pipe(
    map(num => `当前数字是：${num}`)
  );
  

• switchMap/concatMap/mergeMap：基于源值创建新Observable
  如果目标Observable需要依赖源Observable的值生成（比如根据源输出的ID发起新请求），就用这类“高阶映射”操作符：

  • switchMap：每当源Observable有新值时，会取消前一个正在进行的Observable订阅，适合搜索输入这类需要取消旧请求的场景。
  • concatMap：按顺序依次执行每个新生成的Observable，前一个完成后才会执行下一个。
  • mergeMap：并行执行所有生成的Observable，不保证输出顺序。

  举个switchMap的例子，根据用户ID获取用户信息：

  import { of } from 'rxjs';
  import { switchMap } from 'rxjs/operators';
  
  const userId$ = of(1001);
  const userInfo$ = userId$.pipe(
    switchMap(userId => fetchUserInfo(userId)) // fetchUserInfo返回Observable<User>
  );
  

2. 实现operation()返回Observable<bool>，存入processResult的返回值 #

根据你的需求，分几种情况来实现：

情况1：processResult是同步函数，且所需数据已就绪 #

这种情况最简单，直接用of()把同步的布尔值包装成Observable即可：

import { of } from 'rxjs';

operation(): Observable<boolean> {
  // 假设你已经获取到需要传给processResult的data
  const data = this.getSomeData(); 
  const result = this.processResult(data);
  return of(result);
}

情况2：需要手动控制Observable的发送逻辑（比如有异步操作或复杂清理） #

如果涉及异步逻辑，或者需要手动管理订阅的生命周期，用Observable.create()来创建：

import { Observable } from 'rxjs';

operation(): Observable<boolean> {
  return new Observable(observer => {
    try {
      // 这里可以写获取data的逻辑，甚至异步操作
      const data = this.getSomeData();
      const result = this.processResult(data);
      
      // 把processResult的结果发送给订阅者
      observer.next(result);
      // 完成Observable，告诉订阅者没有更多数据了
      observer.complete();
    } catch (error) {
      // 如果出错，发送错误通知
      observer.error(error);
    }

    // 返回清理函数，当订阅取消时执行（比如取消异步请求）
    return () => {
      // 比如：this.cancelAsyncRequest();
    };
  });
}

情况3：所需data来自另一个Observable #

如果data是从另一个Observable获取的，结合第一个问题里的操作符即可：

import { map } from 'rxjs/operators';

operation(): Observable<boolean> {
  // 假设getData()返回Observable<YourDataType>
  return this.getData().pipe(
    map(data => this.processResult(data))
  );
}

内容的提问来源于stack exchange，提问作者Ignacio Soler Garcia