代码之家 › 专栏 › 技术社区 › Emanuel Pinho

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

observable rxjs javascript

Emanuel Pinho · 技术社区 · 6 年前

我有一个对象数组,我需要在每个对象上调用一个返回可观测值的服务,但是如果满足某些条件(例如,服务返回错误),我想停止序列。

const array = [
    {name: 'A', valid: true},
    {name: 'B', valid: true},
    {name: 'C', valid: false},
    {name: 'D', valid: true}
];

const fnc = (obj) => {
    console.log(obj.name);
    return of(obj.valid).pipe(delay(500));
};

在这种情况下,仅记录A和B的可观察算子链应该是什么?

1 回复 | 直到 6 年前

martin 6 年前

如果需要进行单独的异步以确定每个项是否有效,可以简单地使用 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(...);

推荐文章

Fahad Subzwari · 我不能用rxjs过滤器过滤记录?

2 年前

Fazla Elahi Md Jubayer · 在rxjs中使用管道内的两个concatmap时,如何提取订阅块内的结果

3 年前

Irakli · 我想以角度显示id相似的数据

3 年前

Akash · 当BehaviorSubject发出两次真值时,使ngOnChange被激发

7 年前

Shamshiel · 将rxjs升级到6后,类型“Observable”上不存在属性“map”

7 年前

Corey Cole Roberto Tyley · 使用RxJS 6。x WebSocketSubject客户端

7 年前

gog · 如何观察rxjs中的属性更改?

7 年前

jesdynf · 在继续之前,如何使角度拦截器延迟?

7 年前

Sean Ivins · 角度2+HttpIntercept:在返回intercept函数之前,等待来自服务器的令牌

7 年前

Kevin Kalitowski · RxJs 6:从Observable获取ConnectableObservable

7 年前