從RxJava2中的列表中一次取出n個元素

Question

我有一個元素列表，我想從該列表中一次處理n個元素。我怎樣才能以RX的方式做到這一點？

我看了一下take算子，但它只取第n個或最後n個元素。我需要處理列表中的所有元素，但一次處理n個元素。

理想情況下，我應該從一個更大的列表中得到多個大小爲n的列表。

Answer 1

你可以使用window()（或它的一個變種重載的）：

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

或者，如果你不希望有等待窗口「補」，那麼也許buffer()（或之一它的過載變量）：

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