大佬教程收集整理的这篇文章主要介绍了angular – 当另一个Observable(通知程序)发出时,从源Observable发出下一个值，大佬教程大佬觉得挺不错的，现在分享给大家，也给大家做个参考。
source: ---1--2--3--4---------5--------6-|--> notifier: -o------------o-----o---o--o-o------> ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ output: ---1----------2-----3---4--5---6-|-->
所以,我有一个发出值的源Observable,我希望它们中的每一个只有在第二个Observable(称为通知符)发出时才进入输出.这就像通知程序中的一个事件意味着“允许接下来通过”.
我尝试使用delayWhen,但我的主要问题是所有源值都在等待来自通知程序的同一个事件,因此例如如果3个源值“排队”并且通知程序发出一次,则所有3个值都会通过,不是我想要的.
const valueStream =
Rx.observable.from([0,1,2,3,4,5,6]);
const notificationStream =
Rx.observable.interval(1000).take(7);
Rx.observable
.zip(valueStream,notificationStream,(val,notification) => val)
.subscribe(val => console.log(val));
工作示例here.
当从两个流产生一对时,这产生一个值.因此,当notificationStream生成一个值时,该示例将从valueStream中打印一个值.
以上是大佬教程为你收集整理的angular – 当另一个Observable(通知程序)发出时,从源Observable发出下一个值全部内容，希望文章能够帮你解决angular – 当另一个Observable(通知程序)发出时,从源Observable发出下一个值所遇到的程序开发问题。
如果觉得大佬教程网站内容还不错，欢迎将大佬教程推荐给程序员好友。
本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ：384754419，请注明来意。