rxjsを使用した分のストリームの先頭

Question

カレンダーのアラートを使用する場合は、毎分（毎分0秒）、毎分15分（0分0分）で1分ごとに発信するObservableを作成する必要があります、15分、30分、45分など）

タイマーサービスチェック毎分と警告（アラームなどを作成します）

私は次のことを試してみました：

//get 59th second of this minute and start an observable timer 
var date : Date = moment().endOf('minute').toDate(); 
const source = Observable.timer(date, 60000); 

source.subscribe(val => console.log("New Minute: " + moment().format())); 

この作品との発します1分ごとのトップですが、秒はドリフトし、1時間以内には47秒。

これを実行する最善の方法は、毎秒放出し、秒が0であるかどうかを確認することですが、Observableを使用してそれを行う方法がわかりません。

編集：これはAngular 2アプリです。

Answer 1

少し混雑しているようですが、observable.timerを1秒に1回実行してからseconds === 0にフィルタをかけることができます。このように：

const source = Rx.Observable.timer(1000, 1000) 
       .map(x => moment()) 
       .filter(mom => mom.seconds() === 0); 

    source.subscribe(m => console.log(m));