每次发出一个zip 2时就可以观察到

鲍比

我有以下

const timer1 = interval(1000).pipe(take(10));
const timer2 = interval(2000).pipe(take(6));
const merged = merge(timer1, timer2);
merged.subscribe(x => console.log(x));

现在,这将仅提供可观察到的最新发射的值。

我想,当一个发出时,我得到了新的价值,而另一个则得到了最新的价值。

我尝试使用,zip但不会使用最新的。在下面的屏幕截图中查看我希望拥有的缺失值。我怎样才能做到这一点?

联接将起作用,但如果相同的可观察对象在另一个变量发出一个值之前发出了两次,则联接不会发出。

在此处输入图片说明

比兹鲍勃

您正在寻找combineLatest

combineLatest每当观察到的两个源中的任何一个发出时,都将发出。注意:直到每个可观察到的物体至少发射了一次,它才会第一次发射。

结合最新的大理石

因此,以您的示例为例,它看起来可能像这样(StackBlitz):

const timer1 = interval(1000).pipe(take(10));
const timer2 = interval(2000).pipe(take(6));
const merged = combineLatest([timer1, timer2]);

merged.subscribe(([one, two]) => console.log(`${one}-${two}`));

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

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

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章

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

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

当source是一个类时,可以从rxjs中观察到“ this”元素吗?

在两个可观察对象的第一个值都发出之后,Zip不再发出值

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

每次在Angular 2中满足条件时,rxJS即可观察到重复调用

Rx运算符,每次可观察到的源发出新事件时,将“ n”个最新项作为列表发出

每次观察到订阅时如何运行函数

在一个变量中对多个观察进行分类,这样我就可以将它们归类在新的专栏中。如何使代码更短?在R中

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

任一可观察到的更新时触发代码

获取RxJava2中可观察到的N个最后发出的对象

断言观察到一个事件

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

从最后一个项目循环观察到的集合

ViewModel观察到每一个碎片

在Excel VBA中命名对象,以便将其复制到另一个工作表/工作簿后就可以选择它

你是如何做到的,这样你就可以自动重定向到存储在 .txt 文件中的另一个链接?

RXJava-缓冲区可观察到1,直到可观察到2发出一项

我如何在constraintlayout创建一个容器,这样我就可以设置背景?

在结构归纳证明中概括一个要求就可以使用归纳假设

只需添加一个类就可以制作SVG动画

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

RxJava-每秒发出一个可观察的信号

可观察的仅发出一个值?

编写Web组件时如何处理“一旦不再连接元素就可以调用connectedCallback”

RxJava-控制一个可被另一个观察到

可观察到的在angular2中不接收下一个值

暂停和恢复基础上RxJava 2.X一个布尔门可观察到的?