使用exhaustMap调用API时如何正确返回Observable？

问题原因 #

• getProducts函数声明返回Observable<any>，但当前代码没有任何return语句，TypeScript的类型检查会强制要求函数返回匹配类型的值，因此抛出错误。
• 错误使用subscribe()：手动订阅HTTP请求会中断Observable链，回调里的return of(result.data)仅在订阅内部执行，根本不会作为函数的返回值传递给exhaustMap。

正确写法 #

直接返回userService.getUsers的Observable，并用map操作符处理响应数据，全程保持Observable链的完整性，不要手动订阅：

// 修正后的getProducts
private getProducts(startsWith: string, page: number): Observable<any> {
  console.log(`api call filter: ${startsWith}`);

  const take = 10;
  const skip = page > 0 ? (page - 1) * take : 0;

  console.log(`skip: ${skip}, take: ${take}`);

  // 直接返回HTTP请求的Observable，通过map提取需要的data字段
  return this.userService.getUsers(skip, take).pipe(
    map(result => result.data)
  );
}

补充说明 #

• RxJS操作符（如exhaustMap）需要接收Observable作为输入，因此getProducts必须返回Observable类型值，不能通过订阅终止链。
• 当前代码里的startsWith参数尚未使用，后续如果需要根据过滤条件筛选数据，可以将该参数传入getUsers接口，或者在map操作符之前添加filter等逻辑处理数据。

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