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

Question

我希望我的情况很常见但是找不到合适的东西.我想实现的,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个值都通过,这是不是我想要的.

Answer 1

答案是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));

工作示例在这里。

当从两个流产生一对时，这会产生一个值。因此，该示例将在生成值valueStream时打印一个值。notificationStream