当另一个发出值时,可观察到RxJS错误

德文·H

我在这里尝试做的人为示例:

const source = interval(1000);
const errorWhenThisEmits = timer(2500);

source.pipe(/* someOperatorHere? */).subscribe({
  next: () => console.log('next!'),
  error: (err) => console.log(err)
});

// desired outcome:
// 1000ms: next!
// 2000ms: next!
// 2500ms: error message

当第二个可观察源发出值时,是否可能导致可观察源出错?

takeUntil 接近,但完成而不是错误。

MoxxiManagarm

你可以合并观察者

const source = interval(1000);
const notifier = timer(2500).pipe(switchMap(() => throwError("error message")));

merge(source, notifier).subscribe({
  next: () => console.log("next!"),
  error: err => console.log(err)
});

参见stackblitz:https ://stackblitz.com/edit/rxjs-ony9vx ? file = index.ts

本文收集自互联网,转载请注明来源。

如有侵权,请联系 [email protected] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章

RXJS首先发出结果,然后等待另一个可观察到的结果

将MergeMap与从另一个可观察到的数据数组一起使用-RxJs Angular

转发时发出进度项可观察到一个

RxJs:使用发射另一个可观察值来过滤可观察内容

RxJava:等待另一个可观察到的结果

将可观察到的嵌套对象映射到另一个对象

根据另一个对Rx可观察到的Rx进行升采样

* ng如果异步管道与另一个可观察到的角度合并

rxjava按条件收集对象并等待另一个可观察到的对象

将可观察到的Zip列表转换为另一个可观察到的RxJava2

将一个可观察到的称为另一个是正确的吗?

另一个rxjs可观察的重试策略

延迟发射物品,直到从另一个可观察到的物品发射出来

rxjs-缓冲发出的值,直到其他可观察到的发出,然后照常发出

rxjs:如何从catchError的另一个可观察值返回结果

RxJS:为另一个可观察对象设置默认值

将一个可观察到的RxJS结果传递到下一个可观察到的序列中

当另一个可观察值产生任何值时,选择可观察的最新值

RxJs可观察到而没有下一个事件?

rxjs可观察到的debounceTime内部下一个忽略

RxJs可观察到的重复值

根据另一个可观察值的值延迟发射可观察值

尝试向API发出多个请求时出现TypeScript可观察到的错误(Angular,TypeScript,RxJS)

创建一个可观察对象,该对象从另一个可观察对象发出数据子集

RxJava:阻止某个可观察对象发出,直到发出另一个可观察对象的数据

如何使RxJava 2中的可观察对象发出另一个可观察对象发出的组合项?

将RxSwift可观察结果绑定到另一个可观察结果

httpClient的http操作是否总是单一值可观察到的?他们能以某种方式发出多于一个的价值吗?

RxJava可观察到的最后一个状态