javascript - RxJS-等待5个事件发生，然后继续

我有一个简单的RxJS5像这样观察到：

function foo(){

 return Rx.Observable.create(obs => {
          obs.next();
   });

}

可观察对象的创建是这样的：

const x = foo();

function bar(){

     return someObs()
       .flatMap(() => x.wait(5))  // wait for x to fire 5 times
       .map(v => ({z:v}));

}

我想做的是，在继续观察之前，先等待x可观察到的5个事件触发。

我认为take运算符不是我想要的，所以我只是将运算符称为“ wait”

如何使用RxJS5做到这一点？

最佳答案

您要查找的运算符是skip

 return someObs()
   .skip(5)
   .map(v => ({z:v}));

关于javascript - RxJS-等待5个事件发生，然后继续，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/41389447/