RxJava2のリストから一度にn個の要素を取る

Question

私は要素のリストを持っています。そして、そのリストから一度にn個の要素を処理したいと思います。 RXの方法でどうすればいいですか？

私はtake演算子を見ましたが、最初のn個または最後のn個の要素しか取りません。リスト内のすべての要素を処理する必要がありますが、一度にn個は処理しなければなりません。

理想的には、より大きなリストからサイズnの複数のリストを取得する必要があります。

Answer 1

あなたはwindow()（またはその過負荷の変種の1）を使用することができます

observable.window(batchSize).subscribe(...) 

それとも、あなたは「塗りつぶし」にウィンドウを待つ必要がしたくない場合は、おそらくbuffer()（またはのいずれかをそのオーバーロードされた亜種）：

observable.buffer(batchSize).subscribe(...)