满足条件时的可观测停止序列

如果需要进行单独的异步以确定每个项是否有效,可以简单地使用 concatMap :

from(array).pipe(
    concatMap(obj => http.get(...).pipe(mapTo(obj))),
  })
  .subscribe(...);

您说过当一个项无效时服务返回一个错误,因此如果 http.get 呼叫失败 concatMap公司 发出错误。

但是,如果您只想在不发出错误的情况下完成链(或者如果服务在项目无效时不发出错误),则可以使用 takeWhile() :

from(array).pipe(
    concatMap(obj => http.get(...).pipe(
      map(valid => {
        obj.valid = valid;
        return obj;
      }),
    )),
    takeWhile(obj => obj.valid),
  })
  .subscribe(...);