ObservableからN番目の要素をすべて取る

Question

一定の間隔で値を生成するストリームを観察する必要がありますが、生成する10個の値ごとに1つの値をとるように値が大きすぎます。

ことを行うには同等の、非RXの方法で、次のようになります。

int step = 10; // take every 10th value 
var numbers = Enumerable.Range(0, 100).Where((e, i) => i % step == 0); 

Rxの中でそれを行うための慣用的な方法でしょうか？

Answer 1

私はWhereかBufferのいずれかを使用します。

int step = 10; // take every 10th value 

// Where 
var numbers = Observable.Range(0, 100).Where((e, i) => i % step == 0); 

// Buffer 
numbers = Observable.Range(0, 100).Buffer(step).Select(x => x[step - 1]);