如何利用Observable.expand与mergeMap实现批量删除请求？

看起来你已经走对了方向，核心思路就是先通过expand完成所有递归请求，收集所有返回结果后过滤出需要删除的ID，再统一发起批量删除。这里主要需要调整几个点，让逻辑更清晰且符合RxJS的流式风格：

• 让expand专注于递归遍历所有请求，不在递归过程中处理删除逻辑
• 正确收集所有返回对象，过滤出Count === 0的项并提取ID
• 把deleteByIds返回的Promise转换成Observable，融入RxJS流中

修正后的主流程代码 #

import { EMPTY, fromPromise } from 'rxjs';
import { expand, toArray, map, switchMap } from 'rxjs/operators';

// 直接返回Observable流，无需额外Promise包裹
return this.restService.observable.post(CREATE, val).pipe(
  // 递归处理后续请求：只要Count>1就继续获取下一个对象
  expand(response => {
    const obj = response.json();
    if (obj?.Count > 0) {
      return this.restService.observable.get(`${GET_NEXT}?id=${obj.id}`);
    }
    // Count=0或其他情况，终止递归
    return EMPTY;
  }),
  // 将所有递归返回的结果收集为数组
  toArray(),
  // 过滤出需要删除的对象，提取ID数组
  map(responses => {
    return responses
      .map(res => res.json())
      .filter(obj => obj?.Count === 0)
      .map(obj => obj.id);
  }),
  // 发起批量删除：将Promise转为Observable，适配RxJS流
  switchMap(deleteIds => {
    // 无需要删除的ID时，直接返回空流避免无效请求
    if (deleteIds.length === 0) {
      return EMPTY;
    }
    return fromPromise(this.deleteByIds(deleteIds));
  }),
  // 处理批量删除的返回结果
  map(res => res.results)
);

简化后的deleteByIds方法 #

deleteByIds(queryIds) {
  // 直接用传入的数组赋值，简化循环逻辑
  const data = { data: { ids: queryIds } };
  const payload = JSON.stringify(data);
  
  return this.restService.post('deleteBulk', payload)
    .then(response => response.json())
    .catch(error => {
      // 建议不要吞掉错误，便于调试排查
      console.error('批量删除失败:', error);
      throw error;
    });
}

关键调整说明 #

1. expand职责单一化：原来在递归过程中尝试处理删除逻辑，现在只负责判断是否需要继续请求，所有结果交给后续操作符统一处理，逻辑更清晰。
2. RxJS 6+规范写法：改用pipe链式调用操作符，替代老版的链式方法调用，更符合现代RxJS的编码习惯。
3. Promise转Observable：用fromPromise把deleteByIds返回的Promise转换成Observable，确保整个流程保持流式处理，避免Promise嵌套的冗余。
4. 空值边界处理：当没有需要删除的ID时，返回EMPTY流，避免发起无效的批量删除请求。

整个流程逻辑：
发起创建请求 → 递归获取后续对象直到Count=0 → 收集所有结果 → 提取需删除ID → 批量删除 → 返回最终删除结果

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