Nehmen Sie n Elemente aus einer Liste in RxJava2

Question

Ich habe eine Liste von Elementen und ich möchte n Elemente aus dieser Liste gleichzeitig verarbeiten. Wie kann ich es auf RX-Weise machen?

Ich schaute auf take Operator, aber das dauert nur erste n oder letzte n Elemente. Ich muss alle Elemente in einer Liste aber n gleichzeitig verarbeiten.

Idealerweise sollte ich mehrere Listen der Größe n aus einer größeren Liste bekommen.

Answer 1

könnten Sie verwenden window() (oder eines seiner überladenen Varianten):

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

Oder, wenn Sie zu ‚füllen‘ für das Fenster zu warten, nicht haben wollen, dann vielleicht buffer() (oder einer der seine überladenen Varianten):

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