RxJava2, repeatUntil und whileDo

Question

Ich bin mir nicht sicher, dass ich repeatUntil verstehe. Ich wollte so etwas haben:

1. beobachtbaren Erstellen von nur
2. Zustand prüfen und wenn es alle downstreams wahr laufen ist, sonst nur komplette
3. Wiederholen Sie den zweiten Punkt

Hier ist mein Test Observable, die in IndexOutOfBoundsException läuft

List<Integer> values = new ArrayList<Integer>(); 

    Observable<Integer> observable = Observable.just(values) 
      .repeatUntil(() -> values.isEmpty()) 
      .map(integers -> values.remove(0)); 
    observable.subscribe(integer -> System.out.println(integer), 
      throwable -> System.out.println(throwable)); 

Es scheint mir, repeatUntil wird zum ersten Mal am Ende ausgeführt werden.

Bin ich falsch? Und wenn ich recht habe, wie kann ich den Zustand am Anfang überprüfen?

Ich sah auch, dass es whileDo-Operator in rxJava1 gab. Wo ist es jetzt?

UPD

I unter Verwendung von Takewhile vor repeatUntil das Problem irgendwie lösen könnte, aber vielleicht ist es eine bessere Lösung?

List<Integer> values = new ArrayList<Integer>(); 
    /* 
    values.add(0); 
    values.add(1); 
    values.add(2); 
    values.add(3); 
    values.add(4); 
    */ 

    Observable<Integer> observable = Observable.just(values) 
      .takeWhile(integers -> values.size() > 0) 
      .map(integers -> values.remove(0)) 
      .repeatUntil(() -> values.isEmpty()); 
    observable.subscribe(integer -> System.out.println("Test " + integer), 
      throwable -> System.out.println(throwable), 
      () -> System.out.println("Completed")); 

Answer 1

RepeatUntil ruft die Funktion, wenn seine Upstream abgeschlossen ist, das ist, nachdem er den leeren ArrayList signalisiert hat, so dass Sie die Ausnahme, weil die remove, dass leere ArrayList finden.

Der Operator whileDo lebt im Projekt RxJava 2 Extensions.

List<Integer> values = new ArrayList<Integer>(); 

StatementFlowable.whileDo(
    Observable.just(values), 
    () -> values.isEmpty() 
) 
.map(integers -> values.remove(0)) 
.subscribe(integer -> System.out.println(integer), 
     throwable -> System.out.println(throwable)) 
;