angular – 当另一个Observable(通知程序)发出时,从源Observable

发布时间：2020-12-17 08:47:06 所属栏目：安全来源：网络整理

导读：我希望我的情况很常见,但实际上找不到合适的东西.我想在Angular2 / RxJS 5中实现的是： source: ---1--2--3--4---------5--------6-|--notifier: -o------------o-----o---o--o-o------ ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^output: ---1----------2-----3

我希望我的情况很常见,但实际上找不到合适的东西.我想在Angular2 / RxJS 5中实现的是：

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个值都会通过,不是我想要的.

答案是zip：

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中打印一个值.

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!