RxJS - 等待繼續

Question

我有一個簡單RxJS5觀察到，像這樣發生之前5個事件：

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？

Answer 1

你正在尋找的運營商skip

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

Answer 2

好了，它看起來像我可以這樣做：

return this.obsEnqueue.take(5).takeLast(1); 

，因爲我最終只能要等待5個事件

如果有更好的方式來做到這一點火後1個事件， ，就一定喜歡聽到它