RxJava takeUntil mit Auslösung des letzten Artikels?

Question

Gibt es eine Möglichkeit, Artikel zu emittieren, die die Bedingung in takeUntil Operator erfüllen?

Answer 1

Mmmm nicht sicher, ob ich Ihre Frage verstehe. Etwas wie das?

@Test 
public void tesTakeUntil() { 
    List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5); 
    Observable.from(numbers) 
       .takeUntil(number -> number > 3) 
       .subscribe(System.out::println); 

} 

wird es

1 
2 
3 
4 

drucken Sie weitere Beispiele hier Nehmen Sie sehen von https://github.com/politrons/reactive/blob/master/src/test/java/rx/observables/filtering/ObservableTake.java

Answer 2

final String stop = "c"; 
Observable.just("a", "b", "c", "d") 
      .filter(item -> !item.equals(stop)) 
      .takeUntil(item -> item.equals(stop)) 
      .subscribe(System.out::println); 

Ausgang:

c